class RedisReducedPropagationStorage implements ReducedPropagationStorage {

    @Override
    public Future<List<String>> removeExpiredQueues(long currentTS) {
        Future<List<String>> future = Future.future();
        List<String> keys = Collections.singletonList(QUEUE_TIMERS);
        List<String> arguments = Collections.singletonList(String.valueOf(currentTS));
        RemoveExpiredQueuesRedisCommand cmd = new RemoveExpiredQueuesRedisCommand(removeExpiredQueuesRedisCommand,
                keys, arguments, redisClient, log, future);
        cmd.exec(0);
        return future;
    }

    public  RedisReducedPropagationStorage(RedisClient redisClient);

}