From 09014f7f8328a3f12134e04dd63385ca141fc9b7 Mon Sep 17 00:00:00 2001 From: Alex Rudyy Date: Wed, 15 May 2013 23:03:09 +0000 Subject: QPID-4851: Fix ConcurrentModificationException thrown on closing of AMQP 1.0 connection with existing sessions git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1483121 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'java') diff --git a/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java b/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java index 0ad62fd730..09335e3c74 100644 --- a/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java +++ b/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java @@ -334,7 +334,8 @@ public class ConnectionImpl implements Connection, QueueConnection, TopicConnect if(_state != State.CLOSED) { stop(); - for(SessionImpl session : _sessions) + List sessions = new ArrayList(_sessions); + for(SessionImpl session : sessions) { session.close(); } -- cgit v1.2.1