diff options
| author | Alex Rudyy <orudyy@apache.org> | 2013-05-15 23:03:09 +0000 |
|---|---|---|
| committer | Alex Rudyy <orudyy@apache.org> | 2013-05-15 23:03:09 +0000 |
| commit | 2d84923a606d3697cde559cfdda4d4c4b0718a1c (patch) | |
| tree | 920e266f111bd71cff9354de80b3c02f7511e2bf /qpid/java | |
| parent | 1ac96337681e45c51d3b9e55412067cf2fdb4ec1 (diff) | |
| download | qpid-python-2d84923a606d3697cde559cfdda4d4c4b0718a1c.tar.gz | |
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@1483121 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java b/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java index 0ad62fd730..09335e3c74 100644 --- a/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java +++ b/qpid/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<SessionImpl> sessions = new ArrayList<SessionImpl>(_sessions);
+ for(SessionImpl session : sessions)
{
session.close();
}
|