From e37b2b42cb3ac65bc7a1922bfa243bfed14b967b Mon Sep 17 00:00:00 2001
From: Noah Levitt <nlevitt@archive.org>
Date: Thu, 8 Oct 2015 18:11:09 -0700
Subject: [PATCH] avoid spurious logging

---
 .../archive/crawler/frontier/AMQPUrlReceiver.java   | 13 ++++++++-----
 1 file changed, 8 insertions(+), 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
index 918913d7..8483f4fd 100644
--- 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 class AMQPUrlReceiver implements Lifecycle, ApplicationListener<CrawlStat
 
                     Thread.sleep(10 * 1000);
                 } catch (InterruptedException e) {
-
                     return;
                 }
             }
@@ -429,13 +428,17 @@ public class AMQPUrlReceiver implements Lifecycle, ApplicationListener<CrawlStat
     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: