From 9c5680c9f645cb6e3249d65e56e0ba2140038e2b Mon Sep 17 00:00:00 2001
From: Robert Davies <rajdavies@apache.org>
Date: Fri, 3 Mar 2006 19:24:16 +0000
Subject: [PATCH] don't remove connection info from broker if the transport has
 failed

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@382913 13f79535-47bb-0310-9956-ffa450edef68
---
 .../main/java/org/apache/activemq/ActiveMQConnection.java | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
index 662645eb49..f06bd3ceb2 100755
--- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
+++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
@@ -1184,9 +1184,11 @@ public class ActiveMQConnection extends DefaultTransportListener implements Conn
             c.dispose();
         }
 
-        if( isConnectionInfoSentToBroker ) {
-            asyncSendPacket(info.createRemoveCommand());
-            isConnectionInfoSentToBroker = false;
+        if(isConnectionInfoSentToBroker){
+            if(!transportFailed.get()){
+                asyncSendPacket(info.createRemoveCommand());
+            }
+            isConnectionInfoSentToBroker=false;
         }        
         if( userSpecifiedClientID ) {
             info.setClientId(null);