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

Use KahaDB (as now the default store) 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@958329 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2010-06-27 06:05:46 +00:00
parent 9807ee3253
commit dd48ebea00
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
View File

@ -48,7 +48,7 @@ import org.apache.activemq.ActiveMQConnectionFactory;
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 CombinationTestSupport{
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{