Commit 186b9051 authored by yihua.huang's avatar yihua.huang

refactor redisscheduler #118

parent 56f033ce
...@@ -26,11 +26,12 @@ public class RedisScheduler extends DuplicateRemovedScheduler implements Monitor ...@@ -26,11 +26,12 @@ public class RedisScheduler extends DuplicateRemovedScheduler implements Monitor
private static final String ITEM_PREFIX = "item_"; private static final String ITEM_PREFIX = "item_";
public RedisScheduler(String host) { public RedisScheduler(String host) {
pool = new JedisPool(new JedisPoolConfig(), host); this(new JedisPool(new JedisPoolConfig(), host));
} }
public RedisScheduler(JedisPool pool) { public RedisScheduler(JedisPool pool) {
this.pool = pool; this.pool = pool;
setDuplicateRemover(this);
} }
@Override @Override
......
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