From b3dff8d9d698fa17e0b6169eea2e934696dd5fe6 Mon Sep 17 00:00:00 2001
From: Andrew Jackson <Andrew.Jackson@bl.uk>
Date: Tue, 11 Oct 2016 20:42:52 +0100
Subject: [PATCH] Defaulting the message prefetch count to 1000 instead of
 infinity.

---
 .../crawler/frontier/AMQPUrlReceiver.java     | 21 +++----------------
 1 file changed, 3 insertions(+), 18 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 6cf96791..a23e1b55 100644
--- a/contrib/src/main/java/org/archive/crawler/frontier/AMQPUrlReceiver.java
+++ b/contrib/src/main/java/org/archive/crawler/frontier/AMQPUrlReceiver.java
@@ -153,25 +153,10 @@ public class AMQPUrlReceiver
 
     /**
      * The maximum prefetch count to use, meaning the maximum number of messages
-     * to be consumed without being acknowledged. Use 'null' to specify there
-     * should be no upper limit (the default).
+     * to be consumed without being acknowledged. Using 'null' would specify
+     * there should be no upper limit (the default).
      */
-    private Integer prefetchCount = null;
-
-    /**
-     * @return the prefetchCount
-     */
-    public Integer getPrefetchCount() {
-        return prefetchCount;
-    }
-
-    /**
-     * @param prefetchCount
-     *            the prefetchCount to set
-     */
-    public void setPrefetchCount(Integer prefetchCount) {
-        this.prefetchCount = prefetchCount;
-    }
+    private Integer prefetchCount = 1000;
 
     private transient Lock lock = new ReentrantLock(true);