From b56197408a2475cea7c7940323535ad3e3b3fbdf Mon Sep 17 00:00:00 2001
From: Robert Davies <rajdavies@apache.org>
Date: Thu, 28 Jun 2007 03:43:05 +0000
Subject: [PATCH] Test using the AMQ Store

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@551437 13f79535-47bb-0310-9956-ffa450edef68
---
 .../activemq/broker/ft/TransactedTopicMasterSlaveTest.java  | 6 ------
 1 file changed, 6 deletions(-)

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;