diff options
Diffstat (limited to 'qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/SessionImpl.java')
-rw-r--r-- | qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/SessionImpl.java | 13 |
1 files changed, 11 insertions, 2 deletions
diff --git a/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/SessionImpl.java b/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/SessionImpl.java index 75243d1c43..3fa1032111 100644 --- a/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/SessionImpl.java +++ b/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/SessionImpl.java @@ -276,14 +276,23 @@ public class SessionImpl implements Session, QueueSession, TopicSession { _closed = true; _dispatcher.close(); - for(MessageConsumerImpl consumer : _consumers) + + List<MessageConsumerImpl> consumers = null; + List<MessageProducerImpl> producers = null; + synchronized (_session.getEndpoint().getLock()) + { + consumers = new ArrayList<MessageConsumerImpl>(_consumers); + producers = new ArrayList<MessageProducerImpl>(_producers); + } + for(MessageConsumerImpl consumer : consumers) { consumer.close(); } - for(MessageProducerImpl producer : _producers) + for(MessageProducerImpl producer : producers) { producer.close(); } + _session.close(); _connection.removeSession(this); } |