@Test
public void testLockedEnqueueNotUpdatingMonitoringHandlerOnRedisquesFail(TestContext context){

    Async async = context.async();
    /*
     * consume event bus messages directed to redisques and reply with 'failure' for enqueuing
     */
    vertx.eventBus().localConsumer(Address.redisquesAddress(),
            (Handler<Message<JsonObject>>) message -> {
                validateMessage(context, message, QueueOperation.lockedEnqueue, "myQueue", "LockRequester");
                message.reply(new JsonObject().put(STATUS, ERROR));
            });
    HttpRequest request = new HttpRequest(HttpMethod.PUT, "/targetUri", new CaseInsensitiveHeaders(), Buffer.buffer("{\"key\":\"value\"}").getBytes());
    queueClient.lockedEnqueue(request, "myQueue", "LockRequester", event -> async.complete());
    // since redisques answered with a 'failure', the monitoringHandler should not be called
    Mockito.verifyZeroInteractions(monitoringHandler);
}