@Test
public void testRemoveExpiredQueuesAllQueuesExpired(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");
    storage.removeExpiredQueues(50).setHandler(event -> {
        context.assertTrue(event.succeeded());
        context.assertNotNull(event.result());
        context.assertEquals(Arrays.asList("queue_1", "queue_2", "queue_3"), event.result());
        assertQueuesTimersSetContent(0, Collections.emptySet());
        async.complete();
    });
}