From 3c79beeb8a15da544abf96c780b2d7555c47be07 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Thu, 6 Feb 2014 11:29:37 +0000 Subject: restore synchronization to addConsumer in SimpleAMQQueue git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-broker-amqp-1-0-management@1565178 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/java/broker-core/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java b/java/broker-core/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java index 1db0c57a62..f4a9794fcd 100644 --- a/java/broker-core/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java +++ b/java/broker-core/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java @@ -384,7 +384,7 @@ public class SimpleAMQQueue implements AMQQueue, @Override - public QueueConsumer addConsumer(final ConsumerTarget target, + public synchronized QueueConsumer addConsumer(final ConsumerTarget target, final FilterManager filters, final Class messageClass, final String consumerName, -- cgit v1.2.1