activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r958329 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
Date Sun, 27 Jun 2010 06:05:47 GMT
Author: rajdavies
Date: Sun Jun 27 06:05:46 2010
New Revision: 958329

URL: http://svn.apache.org/viewvc?rev=958329&view=rev
Log:
Use KahaDB (as now the default store)

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

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java?rev=958329&r1=958328&r2=958329&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
Sun Jun 27 06:05:46 2010
@@ -48,7 +48,7 @@ import org.apache.activemq.ActiveMQConne
 import org.apache.activemq.CombinationTestSupport;
 import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.command.ActiveMQTopic;
-import org.apache.activemq.store.amq.AMQPersistenceAdapterFactory;
+import org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter;
 import org.apache.activemq.store.kahadb.KahaDBStore;
 import org.apache.activemq.util.IOHelper;
 import org.apache.activemq.util.Wait;
@@ -156,10 +156,9 @@ public class DurableConsumerTest extends
     
     private void configurePersistence(BrokerService broker) throws Exception{
         File dataDirFile = new File("target/" + getName());
-        AMQPersistenceAdapterFactory fact = new AMQPersistenceAdapterFactory();
-        fact.setDataDirectory(dataDirFile);
-        fact.setForceRecoverReferenceStore(true);
-        broker.setPersistenceAdapter(fact.createPersistenceAdapter());
+        KahaDBPersistenceAdapter kahaDBAdapter = new KahaDBPersistenceAdapter();
+        kahaDBAdapter.setDirectory(dataDirFile);
+        broker.setPersistenceAdapter(kahaDBAdapter);
     }
     
     public void testFailover() throws Exception{



Mime
View raw message