This commit is contained in:
gtully 2016-03-11 12:01:18 +00:00
parent 57264bf8dc
commit ae441cbc7d
2 changed files with 4 additions and 2 deletions

View File

@ -98,7 +98,7 @@ public class ConnectorView implements ConnectorViewMBean {
*/ */
@Override @Override
public boolean isUpdateClusterClients() { public boolean isUpdateClusterClients() {
return this.connector.isUpdateClusterClientsOnRemove(); return this.connector.isUpdateClusterClients();
} }
/** /**

View File

@ -820,6 +820,8 @@ public class MBeanTest extends EmbeddedBrokerTestSupport {
super.setUp(); super.setUp();
ManagementContext managementContext = broker.getManagementContext(); ManagementContext managementContext = broker.getManagementContext();
mbeanServer = managementContext.getMBeanServer(); mbeanServer = managementContext.getMBeanServer();
broker.getTransportConnectorByScheme("tcp").setUpdateClusterClientsOnRemove(true);
} }
@Override @Override
@ -1518,7 +1520,7 @@ public class MBeanTest extends EmbeddedBrokerTestSupport {
assertNotNull(connector); assertNotNull(connector);
assertFalse(connector.isRebalanceClusterClients()); assertFalse(connector.isRebalanceClusterClients());
assertFalse(connector.isUpdateClusterClientsOnRemove()); assertTrue(connector.isUpdateClusterClientsOnRemove());
assertFalse(connector.isUpdateClusterClients()); assertFalse(connector.isUpdateClusterClients());
assertFalse(connector.isAllowLinkStealingEnabled()); assertFalse(connector.isAllowLinkStealingEnabled());
} }