syncronize start() and stop()

2026-09-24 22:55:45 +00:00 · 2014-02-03 20:27:51 -08:00
parent 500dafd390
commit 6dbcac40d9
1 changed files with 2 additions and 2 deletions
@@ -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 {