@Test
public void testRemoveExpiredQueuesExpiredQueuesFound(TestContext context) {

    Async async = context.async();
    context.assertFalse(jedis.exists(QUEUE_TIMERS));
    jedis.zadd(QUEUE_TIMERS, 15, "queue_1");
    jedis.zadd(QUEUE_TIMERS, 20, "queue_2");
    jedis.zadd(QUEUE_TIMERS, 25, "queue_3");
    jedis.zadd(QUEUE_TIMERS, 50, "queue_4");
    jedis.zadd(QUEUE_TIMERS, 75, "queue_5");
    storage.removeExpiredQueues(20).setHandler(event -> {
        context.assertTrue(event.succeeded());
        context.assertNotNull(event.result());
        context.assertEquals(Arrays.asList("queue_1", "queue_2"), event.result());
        Set<Tuple> expected = new HashSet<>();
        expected.add(new Tuple("queue_3", 25.0));
        expected.add(new Tuple("queue_4", 50.0));
        expected.add(new Tuple("queue_5", 75.0));
        assertQueuesTimersSetContent(3, expected);
        async.complete();
    });
}