svn commit: r1378102 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkTestSupport.java

[tm...@apache.org]

Author: tmielke
Date: Tue Aug 28 12:21:35 2012
New Revision: 1378102

URL: http://svn.apache.org/viewvc?rev=1378102&view=rev
Log:
Enabling support for JMX (off by default) to NetworkTestSupport

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkTestSupport.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkTestSupport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkTestSupport.java?rev=1378102&r1=1378101&r2=1378102&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkTestSupport.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkTestSupport.java Tue Aug 28 12:21:35 2012
@@ -44,6 +44,7 @@ public class NetworkTestSupport extends 
     protected BrokerService remoteBroker;
     protected SystemUsage remoteMemoryManager;
     protected TransportConnector remoteConnector;
+    protected boolean useJmx = false;
 
     protected void setUp() throws Exception {
         super.setUp();
@@ -61,6 +62,7 @@ public class NetworkTestSupport extends 
         BrokerService broker = BrokerFactory.createBroker(new URI("broker:()/localhost?persistent=false&useJmx=false&"));
         connector = createConnector();
         broker.addConnector(connector);
+        broker.setUseJmx(useJmx);
         return broker;
     }
 
@@ -104,7 +106,7 @@ public class NetworkTestSupport extends 
     protected BrokerService createRemoteBroker(PersistenceAdapter persistenceAdapter) throws Exception {
         BrokerService answer = new BrokerService();
         answer.setBrokerName("remote");
-        answer.setUseJmx(false);
+        answer.setUseJmx(useJmx);
         answer.setPersistenceAdapter(persistenceAdapter);
         return answer;
     }