@Test
public void testUnlockNextQueue(TestContext context){

    Async async = context.async(2);
    Mockito.when(queueCircuitBreakerStorage.popQueueToUnlock())
            .thenReturn(Future.succeededFuture("queue_1"));
    vertx.eventBus().consumer(Address.redisquesAddress(), (Message<JsonObject> event) -> {
        context.assertEquals("deleteLock", event.body().getString("operation"));
        event.reply(new JsonObject().put("status", "ok"));
        async.countDown();
    });
    queueCircuitBreaker.unlockNextQueue().setHandler(event -> {
        context.assertTrue(event.succeeded());
        context.assertEquals("queue_1", event.result());
        verify(queueCircuitBreakerStorage, times(1)).popQueueToUnlock();
        async.countDown();
    });
    async.awaitSuccess();
}