Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-26 03:54:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix for http://issues.apache.org/activemq/browse/AMQ-1250

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581715 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-10-03 20:24:27 +00:00
parent 08841bbde3
commit 7b1fd3484e
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
View File

@ -690,7 +690,13 @@ public class TransportConnection implements Service, Connection, Task, CommandVi
state.setContext(context); state.setContext(context);
state.setConnection(this); state.setConnection(this);
try {
broker.addConnection(context, info); broker.addConnection(context, info);
}catch(Exception e){
brokerConnectionStates.remove(info);
LOG.warn("Failed to add Connection",e);
throw e;
}
if (info.isManageable() && broker.isFaultTolerantConfiguration()) { if (info.isManageable() && broker.isFaultTolerantConfiguration()) {
// send ConnectionCommand // send ConnectionCommand
ConnectionControl command = new ConnectionControl(); ConnectionControl command = new ConnectionControl();