diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2014-02-06 11:29:37 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2014-02-06 11:29:37 +0000 |
| commit | 3c79beeb8a15da544abf96c780b2d7555c47be07 (patch) | |
| tree | 60fcef2bc1bea40584bda0fbaa624b74716e0a5b | |
| parent | 8ef4f8c2a6553c39512d8939eb516d275535a949 (diff) | |
| download | qpid-python-3c79beeb8a15da544abf96c780b2d7555c47be07.tar.gz | |
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
| -rw-r--r-- | java/broker-core/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java | 2 |
1 files changed, 1 insertions, 1 deletions
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<QueueConsumer>, @Override - public QueueConsumer addConsumer(final ConsumerTarget target, + public synchronized QueueConsumer addConsumer(final ConsumerTarget target, final FilterManager filters, final Class<? extends ServerMessage> messageClass, final String consumerName, |