You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2015/08/14 06:44:47 UTC
activemq-artemis git commit: fixing tests
Repository: activemq-artemis
Updated Branches:
refs/heads/master 1d407c2c3 -> 154e9d610
fixing tests
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/154e9d61
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/154e9d61
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/154e9d61
Branch: refs/heads/master
Commit: 154e9d610d05271dbd2004d77c5d16a1fe8b1ae6
Parents: 1d407c2
Author: Clebert Suconic <cl...@apache.org>
Authored: Fri Aug 14 00:44:36 2015 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Fri Aug 14 00:44:39 2015 -0400
----------------------------------------------------------------------
.../activemq/artemis/core/server/impl/LiveOnlyActivation.java | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/154e9d61/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/LiveOnlyActivation.java
----------------------------------------------------------------------
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 11f860c..0a6c07e 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) {