This closes #688
This commit is contained in:
commit
6cc01830d1
artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire
|
@ -155,7 +155,7 @@ public class OpenWireProtocolManager implements ProtocolManager<Interceptor>, Cl
|
||||||
if (context != null && context.decRefCount() == 0) {
|
if (context != null && context.decRefCount() == 0) {
|
||||||
//connection is still there and need to close
|
//connection is still there and need to close
|
||||||
context.getConnection().disconnect(error != null);
|
context.getConnection().disconnect(error != null);
|
||||||
this.connections.remove(this);//what's that for?
|
this.connections.remove(context.getConnection());
|
||||||
this.clientIdSet.remove(clientId);
|
this.clientIdSet.remove(clientId);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue