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{
|