diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/LiveOnlyActivation.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/LiveOnlyActivation.java index 11f860c2c4..0a6c07eb98 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/LiveOnlyActivation.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/LiveOnlyActivation.java @@ -84,6 +84,12 @@ public class LiveOnlyActivation extends Activation { scaleDownServerLocator.close(); scaleDownServerLocator = null; } + + try { + activeMQServer.getNodeManager().stop(); + } + catch (Throwable ignored) { + } } public void freezeConnections(RemotingService remotingService) {