Author: orudyy
Date: Wed May 15 23:03:09 2013
New Revision: 1483121
URL: http://svn.apache.org/r1483121
Log:
QPID-4851: Fix ConcurrentModificationException thrown on closing of AMQP 1.0
connection with existing sessions
Modified:
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java
Modified:
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java?rev=1483121&r1=1483120&r2=1483121&view=diff
==============================================================================
---
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java
(original)
+++
qpid/trunk/qpid/java/amqp-1-0-client-jms/src/main/java/org/apache/qpid/amqp_1_0/jms/impl/ConnectionImpl.java
Wed May 15 23:03:09 2013
@@ -334,7 +334,8 @@ public class ConnectionImpl implements C
if(_state != State.CLOSED)
{
stop();
- for(SessionImpl session : _sessions)
+ List<SessionImpl> sessions = new
ArrayList<SessionImpl>(_sessions);
+ for(SessionImpl session : sessions)
{
session.close();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
