@Test
public void testUnlockNextQueueFailingStorage(TestContext context){

    Async async = context.async();
    Mockito.when(queueCircuitBreakerStorage.popQueueToUnlock())
            .thenReturn(Future.failedFuture("unable to pop queueToUnlock from list"));
    vertx.eventBus().consumer(Address.redisquesAddress(), (Message<JsonObject> event) -> {
        context.fail("Redisques should not have been called when the storage failed");
    });
    queueCircuitBreaker.unlockNextQueue().setHandler(event -> {
        context.assertTrue(event.failed());
        context.assertTrue(event.cause().getMessage().contains("unable to pop queueToUnlock from list"));
        verify(queueCircuitBreakerStorage, times(1)).popQueueToUnlock();
        async.complete();
    });
    async.awaitSuccess();
}