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

This closes #2596

This commit is contained in:
Clebert Suconic 2019-04-02 11:21:14 -04:00
parent 54cfeed918 375f383e90
commit 8b3eeafed0
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/impl/ClusterConnectionImpl.java
View File

@ -439,7 +439,9 @@ public final class ClusterConnectionImpl implements ClusterConnection, AfterConn
if (managementService != null) { if (managementService != null) {
TypedProperties props = new TypedProperties(); TypedProperties props = new TypedProperties();
props.putSimpleStringProperty(new SimpleString("name"), name); props.putSimpleStringProperty(new SimpleString("name"), name);
Notification notification = new Notification(nodeManager.getNodeId().toString(), CoreNotificationType.CLUSTER_CONNECTION_STOPPED, props); //nodeID can be null if there's only a backup
SimpleString nodeId = nodeManager.getNodeId();
Notification notification = new Notification(nodeId == null ? null : nodeId.toString(), CoreNotificationType.CLUSTER_CONNECTION_STOPPED, props);
managementService.sendNotification(notification); managementService.sendNotification(notification);
} }
executor.execute(new Runnable() { executor.execute(new Runnable() {