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 2009/02/27 21:01:39 UTC
svn commit: r748670 -
/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/ActiveMQSupport.java
Author: cwiklik
Date: Fri Feb 27 20:01:39 2009
New Revision: 748670
URL: http://svn.apache.org/viewvc?rev=748670&view=rev
Log:
UIMA-1292 Modified startBroker() to start broker on a given port
Modified:
incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/ActiveMQSupport.java
Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/ActiveMQSupport.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/ActiveMQSupport.java?rev=748670&r1=748669&r2=748670&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/ActiveMQSupport.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/ActiveMQSupport.java Fri Feb 27 20:01:39 2009
@@ -152,16 +152,19 @@
return createConnectionFactory().createConnection();
}
- protected BrokerService createBroker() throws Exception
- {
+ protected BrokerService createBroker() throws Exception {
+ return createBroker(8118, true);
+ }
+ protected BrokerService createBroker(int port, boolean useJmx) throws Exception {
ServerSocket ssocket = null;
- System.out.println("Creating Broker <<<<<<<<<<<<<<<<");
+ System.out.println(">>>> Starting Broker On Port:"+port);
try
{
ssocket = new ServerSocket();
String hostName = ssocket.getInetAddress().getLocalHost().getCanonicalHostName();
- uri = "tcp://" + hostName + ":8118";
+ uri = "tcp://" + hostName +":"+ port;
BrokerService broker = BrokerFactory.createBroker(new URI("broker:()/" + hostName + "?persistent=false"));
+ broker.setUseJmx(useJmx);
tcpConnector = broker.addConnector(uri);