Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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
This commit is contained in:
Robert Davies 2006-03-03 19:24:16 +00:00
parent 62c28d1b77
commit 9c5680c9f6
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
View File

@ -1184,9 +1184,11 @@ public class ActiveMQConnection extends DefaultTransportListener implements Conn
c.dispose(); c.dispose();
} }
if( isConnectionInfoSentToBroker ) { if(isConnectionInfoSentToBroker){
asyncSendPacket(info.createRemoveCommand()); if(!transportFailed.get()){
isConnectionInfoSentToBroker = false; asyncSendPacket(info.createRemoveCommand());
}
isConnectionInfoSentToBroker=false;
} }
if( userSpecifiedClientID ) { if( userSpecifiedClientID ) {
info.setClientId(null); info.setClientId(null);