activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r382913 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
Date Fri, 03 Mar 2006 19:24:18 GMT
Author: rajdavies
Date: Fri Mar  3 11:24:16 2006
New Revision: 382913

URL: http://svn.apache.org/viewcvs?rev=382913&view=rev
Log:
don't remove connection info from broker if the transport has failed

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java?rev=382913&r1=382912&r2=382913&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
Fri Mar  3 11:24:16 2006
@@ -1184,9 +1184,11 @@
             c.dispose();
         }
 
-        if( isConnectionInfoSentToBroker ) {
-            asyncSendPacket(info.createRemoveCommand());
-            isConnectionInfoSentToBroker = false;
+        if(isConnectionInfoSentToBroker){
+            if(!transportFailed.get()){
+                asyncSendPacket(info.createRemoveCommand());
+            }
+            isConnectionInfoSentToBroker=false;
         }        
         if( userSpecifiedClientID ) {
             info.setClientId(null);



Mime
View raw message