avoid spurious logging

internetarchive · Oct 9, 2015 · e37b2b4 · e37b2b4
1 parent e4acb6c
commit e37b2b4
Showing 1 changed file with 8 additions and 5 deletions.
diff --git a/contrib/src/main/java/org/archive/crawler/frontier/AMQPUrlReceiver.java b/contrib/src/main/java/org/archive/crawler/frontier/AMQPUrlReceiver.java
@@ -171,7 +171,6 @@ public void run() {
 
                     Thread.sleep(10 * 1000);
                 } catch (InterruptedException e) {
-
                     return;
                 }
             }
@@ -429,13 +428,17 @@ protected CrawlURI makeCrawlUri(JSONObject jo) throws URIException,
     public void onApplicationEvent(CrawlStateEvent event) {
         switch(event.getState()) {
         case PAUSING: case PAUSED:
-            logger.info("Requesting a pause of the URLConsumer...");
-            this.pauseConsumer = true;
+            if (!this.pauseConsumer) {
+                logger.info("Requesting a pause of the URLConsumer...");
+                this.pauseConsumer = true;
+            }
             break;
 
         case RUNNING:
-            logger.info("Requesting unpause of the URLConsumer...");
-            this.pauseConsumer = false;
+            if (this.pauseConsumer) {
+                logger.info("Requesting unpause of the URLConsumer...");
+                this.pauseConsumer = false;
+            }
             break;
 
         default: