why cycleretry cannot work in QueueScheduler

[yxssfxwzy]

This project is amazing! But I have a tiny question.

I consider the push function of QueueScheduler should be as follows.

public synchronized void push(Request request, Task task) {
        if (request.getExtra(Request.CYCLE_TRIED_TIMES) != null || urls.add(request)) {
            queue.add(request);
        }
}

Hope to receive your reply! Thanks!

[code4craft]

Thanks for report! The reason is I FORGET :(
I add cycleretry as an experimental feature and for RedisScheduler. It seems work well, but I forget to support it in other schedulers.
It will be supported in 0.5.0.

[yxssfxwzy]

Got it. Thanks!