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

ARTEMIS-3138 Shared Nothing Live broker shouldn't try to connect to itself

This commit is contained in:
franz1981 2021-02-24 12:34:36 +01:00 committed by Clebert Suconic
parent a0ce3812ba
commit 03a8e20de2
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/ClusterController.java
View File

@ -198,6 +198,11 @@ public class ClusterController implements ActiveMQComponent {
//this is used for replication so need to use the server packet decoder //this is used for replication so need to use the server packet decoder
serverLocator.setProtocolManagerFactory(ActiveMQServerSideProtocolManagerFactory.getInstance(serverLocator, server.getStorageManager())); serverLocator.setProtocolManagerFactory(ActiveMQServerSideProtocolManagerFactory.getInstance(serverLocator, server.getStorageManager()));
serverLocator.setThreadPools(server.getThreadPool(), server.getScheduledPool()); serverLocator.setThreadPools(server.getThreadPool(), server.getScheduledPool());
SimpleString nodeID = server.getNodeID();
if (nodeID != null) {
// this is used to allow a live server to ignore it's same connector ref
serverLocator.setNodeID(nodeID.toString());
}
try { try {
serverLocator.initialize(); serverLocator.initialize();
} catch (Exception e) { } catch (Exception e) {