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

ARTEMIS-385 small fix

This commit is contained in:
Clebert Suconic 2016-02-04 15:59:00 -05:00
parent de4e2cfe3a
commit f0b8f1e356
1 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionFactoryImpl.java
View File

@ -1337,16 +1337,21 @@ public class ClientSessionFactoryImpl implements ClientSessionFactoryInternal, C
Pair<TransportConfiguration, TransportConfiguration> connectorPair, Pair<TransportConfiguration, TransportConfiguration> connectorPair,
boolean isLast) { boolean isLast) {
if (isLast) { try {
latchFinalTopology.countDown();
}
// if it is our connector then set the live id used for failover // if it is our connector then set the live id used for failover
if (connectorPair.getA() != null && TransportConfigurationUtil.isSameHost(connectorPair.getA(), connectorConfig)) { if (connectorPair.getA() != null && TransportConfigurationUtil.isSameHost(connectorPair.getA(), connectorConfig)) {
liveNodeID = nodeID; liveNodeID = nodeID;
} }
serverLocator.notifyNodeUp(uniqueEventID, nodeID, backupGroupName, scaleDownGroupName, connectorPair, isLast); serverLocator.notifyNodeUp(uniqueEventID, nodeID, backupGroupName, scaleDownGroupName, connectorPair, isLast);
} }
finally {
if (isLast) {
latchFinalTopology.countDown();
}
}
}
@Override @Override
public void notifyNodeDown(long eventTime, String nodeID) { public void notifyNodeDown(long eventTime, String nodeID) {