@Test
public void testUnlockSampleQueuesFailingStorage(TestContext context){

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