Update RedisScheduler.java

修改redisscheduler中获取爬取总数bug
master
SpenceZhou 2015-12-02 17:10:42 +08:00
parent 56e0cd513a
commit 165e5a72eb
1 changed files with 1 additions and 1 deletions

View File

@ -119,7 +119,7 @@ public class RedisScheduler extends DuplicateRemovedScheduler implements Monitor
public int getTotalRequestsCount(Task task) {
Jedis jedis = pool.getResource();
try {
Long size = jedis.scard(getQueueKey(task));
Long size = jedis.scard(getSetKey(task));
return size.intValue();
} finally {
pool.returnResource(jedis);