activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r516169 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java
Date Thu, 08 Mar 2007 20:35:27 GMT
Author: rajdavies
Date: Thu Mar  8 12:35:26 2007
New Revision: 516169

URL: http://svn.apache.org/viewvc?view=rev&rev=516169
Log:
use async=false for now

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java?view=diff&rev=516169&r1=516168&r2=516169
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java
Thu Mar  8 12:35:26 2007
@@ -69,7 +69,7 @@
     }
 
     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 @@
     }
 
     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 @@
         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(){



Mime
View raw message