activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1406782 - in /activemq/activemq-apollo/trunk/apollo-itests/src/test/java/org/apache/activemq/apollo: JmsQueueBrowserTest.java ProducerFlowControlSendFailTest.java
Date Wed, 07 Nov 2012 20:05:14 GMT
Author: chirino
Date: Wed Nov  7 20:05:14 2012
New Revision: 1406782

URL: http://svn.apache.org/viewvc?rev=1406782&view=rev
Log:
Remove dependencies on the activemq 5.x broker.

Modified:
    activemq/activemq-apollo/trunk/apollo-itests/src/test/java/org/apache/activemq/apollo/JmsQueueBrowserTest.java
    activemq/activemq-apollo/trunk/apollo-itests/src/test/java/org/apache/activemq/apollo/ProducerFlowControlSendFailTest.java

Modified: activemq/activemq-apollo/trunk/apollo-itests/src/test/java/org/apache/activemq/apollo/JmsQueueBrowserTest.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-itests/src/test/java/org/apache/activemq/apollo/JmsQueueBrowserTest.java?rev=1406782&r1=1406781&r2=1406782&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-itests/src/test/java/org/apache/activemq/apollo/JmsQueueBrowserTest.java
(original)
+++ activemq/activemq-apollo/trunk/apollo-itests/src/test/java/org/apache/activemq/apollo/JmsQueueBrowserTest.java
Wed Nov  7 20:05:14 2012
@@ -17,7 +17,6 @@
 package org.apache.activemq.apollo;
 
 import junit.framework.Test;
-import org.apache.activemq.broker.region.BaseDestination;
 import org.apache.activemq.command.ActiveMQQueue;
 
 import javax.jms.*;
@@ -179,7 +178,7 @@ public class JmsQueueBrowserTest extends
         // currently browse max page size is ignored for a queue browser consumer
         // only guarantee is a page size - but a snapshot of pagedinpending is
         // used so it is most likely more
-        assertTrue("got at least our expected minimum in the browser: ", i > BaseDestination.MAX_PAGE_SIZE);
+        assertTrue("got at least our expected minimum in the browser: ", i > 200);
 
         assertFalse("nothing left in the browser", browserView.hasMoreElements());
         assertNull("consumer finished", consumer.receiveNoWait());

Modified: activemq/activemq-apollo/trunk/apollo-itests/src/test/java/org/apache/activemq/apollo/ProducerFlowControlSendFailTest.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-itests/src/test/java/org/apache/activemq/apollo/ProducerFlowControlSendFailTest.java?rev=1406782&r1=1406781&r2=1406782&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-itests/src/test/java/org/apache/activemq/apollo/ProducerFlowControlSendFailTest.java
(original)
+++ activemq/activemq-apollo/trunk/apollo-itests/src/test/java/org/apache/activemq/apollo/ProducerFlowControlSendFailTest.java
Wed Nov  7 20:05:14 2012
@@ -19,11 +19,6 @@ package org.apache.activemq.apollo;
 import junit.framework.Test;
 import org.apache.activemq.ActiveMQConnection;
 import org.apache.activemq.ActiveMQConnectionFactory;
-import org.apache.activemq.broker.BrokerService;
-import org.apache.activemq.broker.region.policy.PolicyEntry;
-import org.apache.activemq.broker.region.policy.PolicyMap;
-import org.apache.activemq.broker.region.policy.VMPendingQueueMessageStoragePolicy;
-import org.apache.activemq.broker.region.policy.VMPendingSubscriberMessageStoragePolicy;
 
 import javax.jms.*;
 import java.util.concurrent.atomic.AtomicBoolean;



Mime
View raw message