class QueueClient implements RequestQueue {

    @Override
    public Future<Void> deleteLock(String queue) {
        Future<Void> future = Future.future();
        vertx.eventBus().send(getRedisquesAddress(), buildDeleteLockOperation(queue), (Handler<AsyncResult<Message<JsonObject>>>) event -> {
            if (event.failed()) {
                future.fail(event.cause());
                return;
            }
            if (OK.equals(event.result().body().getString(STATUS))) {
                future.complete();
                return;
            }
            future.fail("Failed to delete lock for queue " + queue);
        });
        return future;
    }

    public  QueueClient(Vertx vertx, MonitoringHandler monitoringHandler);

}