svn commit: r1051983 - /uima/uima-as/trunk/uimaj-as-activemq/src/test/java/org/apache/uima/ee/test/utils/ActiveMQSupport.java

[cw...@apache.org]

Author: cwiklik
Date: Wed Dec 22 16:57:07 2010
New Revision: 1051983

URL: http://svn.apache.org/viewvc?rev=1051983&view=rev
Log:
UIMA-1876 Modified to use amq 5.4.1. Changed the internal broker url to localhost, disabled persistance

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=1051983&r1=1051982&r2=1051983&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 Wed Dec 22 16:57:07 2010
@@ -37,6 +37,7 @@ import org.apache.activemq.broker.Transp
 import org.apache.activemq.broker.region.policy.PolicyEntry;
 import org.apache.activemq.broker.region.policy.PolicyMap;
 import org.apache.activemq.broker.region.policy.SharedDeadLetterStrategy;
+import org.apache.activemq.store.memory.MemoryPersistenceAdapter;
 import org.apache.uima.UIMAFramework;
 import org.apache.uima.adapter.jms.JmsConstants;
 import org.apache.uima.util.Level;
@@ -211,7 +212,7 @@ public class ActiveMQSupport extends Tes
     System.out.println(">>>> Starting Broker On Port:" + port);
     try {
       ssocket = new ServerSocket();
-      String hostName = ssocket.getInetAddress().getLocalHost().getCanonicalHostName();
+      String hostName = "localhost"; //ssocket.getInetAddress().getLocalHost().getCanonicalHostName();
       uri = "tcp://" + hostName + ":" + port;
       BrokerService broker = BrokerFactory.createBroker(new URI("broker:()/" + hostName
               + "?persistent=false"));
@@ -228,6 +229,16 @@ public class ActiveMQSupport extends Tes
       pMap.setDefaultEntry(policy);
 
       broker.setDestinationPolicy(pMap);
+      broker.setPersistenceAdapter(new MemoryPersistenceAdapter());
+      broker.setPersistent(false);
+      broker.setUseShutdownHook(true);
+      broker.setUseLoggingForShutdownErrors(false);
+      try {
+          Method method = broker.getClass().getDeclaredMethod("setSchedulerSupport", new Class[] {Boolean.TYPE});
+          method.invoke(broker, new Object[] {Boolean.FALSE});
+      } catch( NoSuchMethodException e) {
+    	  //	ignore
+      }
 
       return broker;
     } finally {