Commit 4a035e72 authored by yihua.huang's avatar yihua.huang

extension point for LocalDuplicatedRemovedScheduler #95

parent b249e497
...@@ -24,11 +24,15 @@ public abstract class LocalDuplicatedRemovedScheduler implements Scheduler { ...@@ -24,11 +24,15 @@ public abstract class LocalDuplicatedRemovedScheduler implements Scheduler {
@Override @Override
public void push(Request request, Task task) { public void push(Request request, Task task) {
logger.trace("get a candidate url {}", request.getUrl()); logger.trace("get a candidate url {}", request.getUrl());
if (request.getExtra(Request.CYCLE_TRIED_TIMES) != null || urls.add(request.getUrl())) { if (urls.add(request.getUrl()) || shouldReserved(request)) {
logger.debug("push to queue {}", request.getUrl()); logger.debug("push to queue {}", request.getUrl());
pushWhenNoDuplicate(request, task); pushWhenNoDuplicate(request, task);
} }
} }
protected boolean shouldReserved(Request request) {
return request.getExtra(Request.CYCLE_TRIED_TIMES) != null;
}
protected abstract void pushWhenNoDuplicate(Request request, Task task); protected abstract void pushWhenNoDuplicate(Request request, Task task);
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment