class RedisQueueCircuitBreakerStorage implements QueueCircuitBreakerStorage {

    @Override
    public Future<String> popQueueToUnlock() {
        Future<String> future = Future.future();
        redisClient.lpop(STORAGE_QUEUES_TO_UNLOCK, event -> {
            if(event.failed()){
                future.fail(event.cause().getMessage());
                return;
            }
            future.complete(event.result());
        });
        return future;
    }

    public  RedisQueueCircuitBreakerStorage(RedisClient redisClient);

}