@Test
public void testDeleteAllQueueItemsWithRedisquesFail(TestContext context){

    Async async = context.async();
    /*
     * consume event bus messages directed to redisques and verify message content.
     * reply with 'failed' for deleteAllQueueItems
     */
    vertx.eventBus().localConsumer(Address.redisquesAddress(), (Handler<Message<JsonObject>>) message -> {
        validateMessage(context, message, QueueOperation.deleteAllQueueItems, "myQueueToDeleteAndUnlock", true);
        message.fail(0, "boom");
    });
    queueClient.deleteAllQueueItems("myQueueToDeleteAndUnlock", true).setHandler(event -> {
        context.assertTrue(event.failed());
        context.assertTrue(event.cause().getMessage().contains("Failed to delete all queue items for queue myQueueToDeleteAndUnlock with unlock true"));
        async.complete();
    });
}