class QueueClient implements RequestQueue {

    @Override
    public Future<Void> deleteAllQueueItems(String queue, boolean unlock) {
        Future<Void> future = Future.future();
        vertx.eventBus().send(getRedisquesAddress(), buildDeleteAllQueueItemsOperation(queue, unlock), (Handler<AsyncResult<Message<JsonObject>>>) event -> {
            if (event.succeeded()) {
                future.complete();
            } else {
                future.fail("Failed to delete all queue items for queue " + queue + " with unlock " + unlock + ". Cause: " + event.cause());
            }
        });
        return future;
    }

    public  QueueClient(Vertx vertx, MonitoringHandler monitoringHandler);

}