activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject activemq-artemis git commit: fixing tests
Date Fri, 14 Aug 2015 04:44:47 GMT
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 <clebertsuconic@apache.org>
Authored: Fri Aug 14 00:44:36 2015 -0400
Committer: Clebert Suconic <clebertsuconic@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) {


Mime
View raw message