You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2014/06/10 16:46:24 UTC
svn commit: r1601655 -
/uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/ActiveMQSupport.java
Author: cwiklik
Date: Tue Jun 10 14:46:24 2014
New Revision: 1601655
URL: http://svn.apache.org/r1601655
Log:
UIMA-3879 update to use port 1098 for jmx
Modified:
uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/ActiveMQSupport.java
Modified: uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/ActiveMQSupport.java
URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/ActiveMQSupport.java?rev=1601655&r1=1601654&r2=1601655&view=diff
==============================================================================
--- uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/ActiveMQSupport.java (original)
+++ uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/ActiveMQSupport.java Tue Jun 10 14:46:24 2014
@@ -100,6 +100,7 @@ public class ActiveMQSupport extends Tes
broker = createBroker(); // sets uri
broker.setUseJmx(true);
+ broker.getManagementContext().setConnectorPort(1098);
broker.start();
broker.setMasterConnectorURI(uri);
addHttpConnector(DEFAULT_HTTP_PORT);
@@ -216,6 +217,7 @@ public class ActiveMQSupport extends Tes
}
protected String getBrokerUri() {
+// return "failover:("+uri+")";
return uri;
}
@@ -246,6 +248,9 @@ public class ActiveMQSupport extends Tes
tcpConnector.setName(DEFAULT_BROKER_URL_KEY);
}
broker.setUseJmx(useJmx);
+ if ( useJmx) {
+ broker.getManagementContext().setConnectorPort(1097);
+ }
PolicyEntry policy = new PolicyEntry();
policy.setDeadLetterStrategy(new SharedDeadLetterStrategy());
@@ -287,6 +292,7 @@ public class ActiveMQSupport extends Tes
broker.deleteAllMessages();
broker.stop();
broker.waitUntilStopped();
+// cleanBroker(broker);
System.out.println(">>> Broker Stopped");
}
}
@@ -296,7 +302,6 @@ public class ActiveMQSupport extends Tes
System.clearProperty("activemq.broker.jmx.domain");
System.clearProperty("BrokerURL");
stopBroker();
-
}
}