You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2016/03/11 13:02:28 UTC
activemq git commit: https://issues.apache.org/jira/browse/AMQ-6208 -
fix and test
Repository: activemq
Updated Branches:
refs/heads/master 57264bf8d -> ae441cbc7
https://issues.apache.org/jira/browse/AMQ-6208 - fix and test
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/ae441cbc
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/ae441cbc
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/ae441cbc
Branch: refs/heads/master
Commit: ae441cbc7dc8d656990cefae28657eed78cf28e0
Parents: 57264bf
Author: gtully <ga...@gmail.com>
Authored: Fri Mar 11 12:01:18 2016 +0000
Committer: gtully <ga...@gmail.com>
Committed: Fri Mar 11 12:01:18 2016 +0000
----------------------------------------------------------------------
.../main/java/org/apache/activemq/broker/jmx/ConnectorView.java | 2 +-
.../src/test/java/org/apache/activemq/broker/jmx/MBeanTest.java | 4 +++-
2 files changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/ae441cbc/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectorView.java
----------------------------------------------------------------------
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectorView.java b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectorView.java
index 51d104b..907829d 100755
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectorView.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectorView.java
@@ -98,7 +98,7 @@ public class ConnectorView implements ConnectorViewMBean {
*/
@Override
public boolean isUpdateClusterClients() {
- return this.connector.isUpdateClusterClientsOnRemove();
+ return this.connector.isUpdateClusterClients();
}
/**
http://git-wip-us.apache.org/repos/asf/activemq/blob/ae441cbc/activemq-unit-tests/src/test/java/org/apache/activemq/broker/jmx/MBeanTest.java
----------------------------------------------------------------------
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/jmx/MBeanTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/jmx/MBeanTest.java
index e03cb46..5304424 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/jmx/MBeanTest.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/jmx/MBeanTest.java
@@ -820,6 +820,8 @@ public class MBeanTest extends EmbeddedBrokerTestSupport {
super.setUp();
ManagementContext managementContext = broker.getManagementContext();
mbeanServer = managementContext.getMBeanServer();
+
+ broker.getTransportConnectorByScheme("tcp").setUpdateClusterClientsOnRemove(true);
}
@Override
@@ -1518,7 +1520,7 @@ public class MBeanTest extends EmbeddedBrokerTestSupport {
assertNotNull(connector);
assertFalse(connector.isRebalanceClusterClients());
- assertFalse(connector.isUpdateClusterClientsOnRemove());
+ assertTrue(connector.isUpdateClusterClientsOnRemove());
assertFalse(connector.isUpdateClusterClients());
assertFalse(connector.isAllowLinkStealingEnabled());
}