From b5a42599b1c61c5bcae34936ef86e4f79c5a912d Mon Sep 17 00:00:00 2001 From: Robert Davies Date: Thu, 8 Mar 2007 20:35:26 +0000 Subject: [PATCH] use async=false for now git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516169 13f79535-47bb-0310-9956-ffa450edef68 --- .../activemq/bugs/JmsDurableTopicSlowReceiveTest.java | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/activemq-core/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java b/activemq-core/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java index 23fa2d7b3f..b35740aff8 100755 --- a/activemq-core/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java @@ -69,7 +69,7 @@ public class JmsDurableTopicSlowReceiveTest extends JmsTopicSendReceiveTest{ } protected ActiveMQConnectionFactory createConnectionFactory() throws Exception{ - ActiveMQConnectionFactory result=new ActiveMQConnectionFactory("vm://localhost"); + ActiveMQConnectionFactory result=new ActiveMQConnectionFactory("vm://localhost?async=false"); Properties props=new Properties(); props.put("prefetchPolicy.durableTopicPrefetch","5"); props.put("prefetchPolicy.optimizeDurableTopicPrefetch","5"); @@ -85,9 +85,6 @@ public class JmsDurableTopicSlowReceiveTest extends JmsTopicSendReceiveTest{ } 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); } @@ -104,7 +101,7 @@ public class JmsDurableTopicSlowReceiveTest extends JmsTopicSendReceiveTest{ session2=connection2.createSession(false,Session.AUTO_ACKNOWLEDGE); consumerDestination2=session2.createTopic(getConsumerSubject()+"2"); consumer2=consumeSession2.createDurableSubscriber((Topic)consumerDestination2,getName()); - Thread.sleep(1000); + consumer2.close(); connection2.close(); new Thread(new Runnable(){