svn commit: r551437 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ft/TransactedTopicMasterSlaveTest.java

[ra...@apache.org]

Author: rajdavies
Date: Wed Jun 27 20:43:05 2007
New Revision: 551437

URL: http://svn.apache.org/viewvc?view=rev&rev=551437
Log:
Test using the AMQ Store

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ft/TransactedTopicMasterSlaveTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ft/TransactedTopicMasterSlaveTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ft/TransactedTopicMasterSlaveTest.java?view=diff&rev=551437&r1=551436&r2=551437
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ft/TransactedTopicMasterSlaveTest.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ft/TransactedTopicMasterSlaveTest.java Wed Jun 27 20:43:05 2007
@@ -17,12 +17,10 @@
  */
 package org.apache.activemq.broker.ft;
 
-import java.io.File;
 import java.net.URISyntaxException;
 import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.JmsTopicTransactionTest;
 import org.apache.activemq.broker.BrokerService;
-import org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter;
 import org.apache.activemq.test.JmsResourceProvider;
 /**
  * Test failover for Queues
@@ -39,10 +37,8 @@
         // this will create the main (or master broker)
         broker=createBroker();
         broker.start();
-        KahaPersistenceAdapter adaptor=new KahaPersistenceAdapter();
         slave = new BrokerService();
         slave.setBrokerName("slave");
-        slave.setPersistenceAdapter(adaptor);
         slave.addConnector("tcp://localhost:62002");
         slave.setDeleteAllMessagesOnStartup(true);
         slave.setMasterConnectorURI("tcp://localhost:62001");
@@ -66,8 +62,6 @@
     protected BrokerService createBroker() throws Exception,URISyntaxException{
         BrokerService broker=new BrokerService();
         broker.setBrokerName("master");
-        KahaPersistenceAdapter adaptor=new KahaPersistenceAdapter();
-        broker.setPersistenceAdapter(adaptor);
         broker.addConnector("tcp://localhost:62001");
         broker.setDeleteAllMessagesOnStartup(true);
         return broker;