From 6dbcac40d94ef9b8b28be22c1562230eb0844320 Mon Sep 17 00:00:00 2001
From: Noah Levitt <nlevitt@archive.org>
Date: Mon, 3 Feb 2014 20:27:51 -0800
Subject: [PATCH] syncronize start() and stop()

---
 .../java/org/archive/crawler/frontier/AMQPUrlReceiver.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 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 e54f7425..36c29d23 100644
--- a/contrib/src/main/java/org/archive/crawler/frontier/AMQPUrlReceiver.java
+++ b/contrib/src/main/java/org/archive/crawler/frontier/AMQPUrlReceiver.java
@@ -92,7 +92,7 @@ public class AMQPUrlReceiver implements Lifecycle {
     }
 
     @Override
-    public void start() {
+    synchronized public void start() {
         while (!isRunning) {
             try {
                 Consumer consumer = new UrlConsumer(channel());
@@ -110,7 +110,7 @@ public class AMQPUrlReceiver implements Lifecycle {
     }
 
     @Override
-    public void stop() {
+    synchronized public void stop() {
         logger.info("shutting down");
         if (connection != null && connection.isOpen()) {
             try {