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

Test using the AMQ Store 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@551437 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-06-28 03:43:05 +00:00
parent a3e382199c
commit b56197408a
1 changed files with 0 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/src/test/java/org/apache/activemq/broker/ft/TransactedTopicMasterSlaveTest.java
View File

@ -17,12 +17,10 @@
*/ */
package org.apache.activemq.broker.ft; package org.apache.activemq.broker.ft;
import java.io.File;
import java.net.URISyntaxException; import java.net.URISyntaxException;
import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.JmsTopicTransactionTest; import org.apache.activemq.JmsTopicTransactionTest;
import org.apache.activemq.broker.BrokerService; import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter;
import org.apache.activemq.test.JmsResourceProvider; import org.apache.activemq.test.JmsResourceProvider;
/** /**
* Test failover for Queues * Test failover for Queues
@ -39,10 +37,8 @@ public class TransactedTopicMasterSlaveTest extends JmsTopicTransactionTest{
// this will create the main (or master broker) // this will create the main (or master broker)
broker=createBroker(); broker=createBroker();
broker.start(); broker.start();
KahaPersistenceAdapter adaptor=new KahaPersistenceAdapter();
slave = new BrokerService(); slave = new BrokerService();
slave.setBrokerName("slave"); slave.setBrokerName("slave");
slave.setPersistenceAdapter(adaptor);
slave.addConnector("tcp://localhost:62002"); slave.addConnector("tcp://localhost:62002");
slave.setDeleteAllMessagesOnStartup(true); slave.setDeleteAllMessagesOnStartup(true);
slave.setMasterConnectorURI("tcp://localhost:62001"); slave.setMasterConnectorURI("tcp://localhost:62001");
@ -66,8 +62,6 @@ public class TransactedTopicMasterSlaveTest extends JmsTopicTransactionTest{
protected BrokerService createBroker() throws Exception,URISyntaxException{ protected BrokerService createBroker() throws Exception,URISyntaxException{
BrokerService broker=new BrokerService(); BrokerService broker=new BrokerService();
broker.setBrokerName("master"); broker.setBrokerName("master");
KahaPersistenceAdapter adaptor=new KahaPersistenceAdapter();
broker.setPersistenceAdapter(adaptor);
broker.addConnector("tcp://localhost:62001"); broker.addConnector("tcp://localhost:62001");
broker.setDeleteAllMessagesOnStartup(true); broker.setDeleteAllMessagesOnStartup(true);
return broker; return broker;