lee/heritrix3
1
0
Fork 0
mirror of https://github.com/internetarchive/heritrix3.git synced 2026-09-25 23:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix log messages to say "kafka"

Browse Source
This commit is contained in:
Noah Levitt
2014-11-05 14:03:54 -08:00
parent 77e2a47c4c
commit 23fa29d673
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
contrib/src/main/java/org/archive/modules/postprocessor/KafkaCrawlLogFeed.java
+2 -2
View File
@@ -148,9 +148,9 @@ public class KafkaCrawlLogFeed extends Processor implements Lifecycle {
}
};
logger.info("dumping " + frontier.queuedUriCount() + " queued urls to amqp feed");
logger.info("dumping " + frontier.queuedUriCount() + " queued urls to kafka feed");
((BdbFrontier) frontier).forAllPendingDo(closure);
logger.info("dumped " + pendingDumpedCount + " queued urls to amqp feed");
logger.info("dumped " + pendingDumpedCount + " queued urls to kafka feed");
} else {
logger.warning("frontier is not a BdbFrontier, cannot dumpPendingAtClose");
}