From 165e5a72eb08318db7cc75906695f2cf2427ac0e Mon Sep 17 00:00:00 2001 From: SpenceZhou Date: Wed, 2 Dec 2015 17:10:42 +0800 Subject: [PATCH] Update RedisScheduler.java MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 修改redisscheduler中获取爬取总数bug --- .../java/us/codecraft/webmagic/scheduler/RedisScheduler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/webmagic-extension/src/main/java/us/codecraft/webmagic/scheduler/RedisScheduler.java b/webmagic-extension/src/main/java/us/codecraft/webmagic/scheduler/RedisScheduler.java index bbb945c..1de718a 100644 --- a/webmagic-extension/src/main/java/us/codecraft/webmagic/scheduler/RedisScheduler.java +++ b/webmagic-extension/src/main/java/us/codecraft/webmagic/scheduler/RedisScheduler.java @@ -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);