diff --git a/activemq-core/src/test/java/org/apache/activemq/broker/ft/TransactedTopicMasterSlaveTest.java b/activemq-core/src/test/java/org/apache/activemq/broker/ft/TransactedTopicMasterSlaveTest.java
index a6a5808885..46b1299cc7 100644
--- a/activemq-core/src/test/java/org/apache/activemq/broker/ft/TransactedTopicMasterSlaveTest.java
+++ b/activemq-core/src/test/java/org/apache/activemq/broker/ft/TransactedTopicMasterSlaveTest.java
@@ -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 @@ public class TransactedTopicMasterSlaveTest extends JmsTopicTransactionTest{
         // 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 @@ public class TransactedTopicMasterSlaveTest extends JmsTopicTransactionTest{
     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;