Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

https://issues.apache.org/activemq/browse/AMQ-1112 - test both values of optimizedDispatch 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@812217 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2009-09-07 16:19:41 +00:00
parent 8d9f47aa48
commit f7804bda6c
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-core/src/test/java/org/apache/activemq/usecases/ExpiredMessagesWithNoConsumerTest.java
View File

@ -49,6 +49,7 @@ public class ExpiredMessagesWithNoConsumerTest extends CombinationTestSupport {
Session session; Session session;
MessageProducer producer; MessageProducer producer;
public ActiveMQDestination destination = new ActiveMQQueue("test"); public ActiveMQDestination destination = new ActiveMQQueue("test");
public boolean optimizedDispatch = true;
public static Test suite() { public static Test suite() {
return suite(ExpiredMessagesWithNoConsumerTest.class); return suite(ExpiredMessagesWithNoConsumerTest.class);
@ -75,8 +76,7 @@ public class ExpiredMessagesWithNoConsumerTest extends CombinationTestSupport {
PolicyMap policyMap = new PolicyMap(); PolicyMap policyMap = new PolicyMap();
PolicyEntry defaultEntry = new PolicyEntry(); PolicyEntry defaultEntry = new PolicyEntry();
// TODO Optimize dispatch makes this test hang defaultEntry.setOptimizedDispatch(optimizedDispatch );
defaultEntry.setOptimizedDispatch(true);
defaultEntry.setExpireMessagesPeriod(100); defaultEntry.setExpireMessagesPeriod(100);
defaultEntry.setMaxExpirePageSize(800); defaultEntry.setMaxExpirePageSize(800);
@ -94,6 +94,10 @@ public class ExpiredMessagesWithNoConsumerTest extends CombinationTestSupport {
broker.waitUntilStarted(); broker.waitUntilStarted();
} }
public void initCombosForTestExpiredMessagesWithNoConsumer() {
addCombinationValues("optimizedDispatch", new Object[] {Boolean.TRUE, Boolean.FALSE});
}
public void testExpiredMessagesWithNoConsumer() throws Exception { public void testExpiredMessagesWithNoConsumer() throws Exception {
createBrokerWithMemoryLimit(); createBrokerWithMemoryLimit();