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;