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

use async=false for now 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516169 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-03-08 20:35:26 +00:00
parent 17c1ed7174
commit b5a42599b1
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
activemq-core/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java
View File

@ -69,7 +69,7 @@ public class JmsDurableTopicSlowReceiveTest extends JmsTopicSendReceiveTest{
} }
protected ActiveMQConnectionFactory createConnectionFactory() throws Exception{ protected ActiveMQConnectionFactory createConnectionFactory() throws Exception{
ActiveMQConnectionFactory result=new ActiveMQConnectionFactory("vm://localhost"); ActiveMQConnectionFactory result=new ActiveMQConnectionFactory("vm://localhost?async=false");
Properties props=new Properties(); Properties props=new Properties();
props.put("prefetchPolicy.durableTopicPrefetch","5"); props.put("prefetchPolicy.durableTopicPrefetch","5");
props.put("prefetchPolicy.optimizeDurableTopicPrefetch","5"); props.put("prefetchPolicy.optimizeDurableTopicPrefetch","5");
@ -85,9 +85,6 @@ public class JmsDurableTopicSlowReceiveTest extends JmsTopicSendReceiveTest{
} }
protected void configureBroker(BrokerService answer) throws Exception{ protected void configureBroker(BrokerService answer) throws Exception{
// KahaPersistenceAdapter adapter=new KahaPersistenceAdapter(new File("activemq-data/durableTest"));
// JDBCPersistenceAdapter adapter = new JDBCPersistenceAdapter();
// answer.setPersistenceAdapter(adapter);
answer.setDeleteAllMessagesOnStartup(true); answer.setDeleteAllMessagesOnStartup(true);
} }
@ -104,7 +101,7 @@ public class JmsDurableTopicSlowReceiveTest extends JmsTopicSendReceiveTest{
session2=connection2.createSession(false,Session.AUTO_ACKNOWLEDGE); session2=connection2.createSession(false,Session.AUTO_ACKNOWLEDGE);
consumerDestination2=session2.createTopic(getConsumerSubject()+"2"); consumerDestination2=session2.createTopic(getConsumerSubject()+"2");
consumer2=consumeSession2.createDurableSubscriber((Topic)consumerDestination2,getName()); consumer2=consumeSession2.createDurableSubscriber((Topic)consumerDestination2,getName());
Thread.sleep(1000);
consumer2.close(); consumer2.close();
connection2.close(); connection2.close();
new Thread(new Runnable(){ new Thread(new Runnable(){