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 2016/03/02 21:05:16 UTC

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

Author: cwiklik
Date: Wed Mar  2 20:05:16 2016
New Revision: 1733359

URL: http://svn.apache.org/viewvc?rev=1733359&view=rev
Log:
UIMA-4813 removed deleteAllMessages() call to make tests work with AMQ 5.13.1

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=1733359&r1=1733358&r2=1733359&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 Mar  2 20:05:16 2016
@@ -33,6 +33,7 @@ import junit.framework.TestCase;
 import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.broker.BrokerFactory;
 import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.BrokerStoppedException;
 import org.apache.activemq.broker.TransportConnector;
 import org.apache.activemq.broker.region.policy.PolicyEntry;
 import org.apache.activemq.broker.region.policy.PolicyMap;
@@ -120,7 +121,7 @@ public class ActiveMQSupport extends Tes
   
   protected void cleanBroker( BrokerService targetBroker) throws Exception {
     // Remove messages from all queues
-    targetBroker.deleteAllMessages();
+   // targetBroker.deleteAllMessages();
     org.apache.activemq.broker.Connection[] connections = targetBroker.getRegionBroker().getClients();
     for( org.apache.activemq.broker.Connection connection : connections) {
       try {