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 {