@Test
public void testUnlockSampleQueuesFailingUnlock(TestContext context){

    Async async = context.async(4);
    Mockito.when(queueCircuitBreakerStorage.unlockSampleQueues())
            .thenReturn(Future.succeededFuture(Arrays.asList("q1", "q2", "q3")));
    vertx.eventBus().consumer(Address.redisquesAddress(), (Message<JsonObject> event) -> {
        context.assertEquals("deleteLock", event.body().getString("operation"));
        if(event.body().getJsonObject("payload").getString("queuename").equalsIgnoreCase("q2")){
            event.reply(new JsonObject().put("status", "error"));
        } else {
            event.reply(new JsonObject().put("status", "ok"));
        }
        async.countDown();
    });
    queueCircuitBreaker.unlockSampleQueues().setHandler(event -> {
        context.assertTrue(event.failed());
        context.assertTrue(event.cause().getMessage().contains("The following queues could not be unlocked: [q2]"));
        async.countDown();
    });
    async.awaitSuccess();
}