class RedisReducedPropagationStorage implements ReducedPropagationStorage {

    @Override
    public Future<Boolean> addQueue(String queue, long expireTS) {
        Future<Boolean> future = Future.future();
        List<String> keys = Collections.singletonList(QUEUE_TIMERS);
        List<String> arguments = Arrays.asList(queue, String.valueOf(expireTS));
        StartQueueTimerRedisCommand cmd = new StartQueueTimerRedisCommand(startQueueTimerLuaScriptState,
                keys, arguments, redisClient, log, future);
        cmd.exec(0);
        return future;
    }

    public  RedisReducedPropagationStorage(RedisClient redisClient);

}