activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dej...@apache.org
Subject svn commit: r1079782 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
Date Wed, 09 Mar 2011 13:06:43 GMT
Author: dejanb
Date: Wed Mar  9 13:06:43 2011
New Revision: 1079782

URL: http://svn.apache.org/viewvc?rev=1079782&view=rev
Log:
https://issues.apache.org/jira/browse/AMQ-3198 - don't unregister original connection

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java?rev=1079782&r1=1079781&r2=1079782&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
Wed Mar  9 13:06:43 2011
@@ -697,7 +697,6 @@ public class TransportConnection impleme
             synchronized (brokerConnectionStates) {
                 brokerConnectionStates.remove(info.getConnectionId());
             }
-            unregisterConnectionState(info.getConnectionId());
             LOG.warn("Failed to add Connection " + info.getConnectionId() + ", reason: "
+  e.toString());
             if (LOG.isDebugEnabled()) {
                 LOG.debug("Exception detail:", e);



Mime
View raw message