activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r581715 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
Date Wed, 03 Oct 2007 20:24:29 GMT
Author: rajdavies
Date: Wed Oct  3 13:24:27 2007
New Revision: 581715

URL: http://svn.apache.org/viewvc?rev=581715&view=rev
Log:
Fix for http://issues.apache.org/activemq/browse/AMQ-1250

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=581715&r1=581714&r2=581715&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 Oct  3 13:24:27 2007
@@ -690,7 +690,13 @@
         state.setContext(context);
         state.setConnection(this);
 
+        try {
         broker.addConnection(context, info);
+        }catch(Exception e){
+        	brokerConnectionStates.remove(info);
+        	LOG.warn("Failed to add Connection",e);
+        	throw e;
+        }
         if (info.isManageable() && broker.isFaultTolerantConfiguration()) {
             // send ConnectionCommand
             ConnectionControl command = new ConnectionControl();



Mime
View raw message