1 18 package org.apache.activemq.systest.usecase.network; 19 20 import org.apache.activemq.systest.BrokerAgent; 21 import org.apache.activemq.systest.ConsumerAgent; 22 import org.apache.activemq.systest.MessageList; 23 import org.apache.activemq.systest.ProducerAgent; 24 25 29 public class TwoBrokerNetworkConnectedBeforeStartScenario extends TwoBrokerNetworkScenario { 30 31 public TwoBrokerNetworkConnectedBeforeStartScenario(BrokerAgent brokera, BrokerAgent brokerb, ProducerAgent producer, ConsumerAgent consumer, 32 MessageList list) { 33 super(brokera, brokerb, producer, consumer, list); 34 } 35 36 protected void startBrokers() throws Exception { 37 brokerB.connectTo(brokerA); 38 brokerA.connectTo(brokerB); 39 40 start(brokerA); 41 start(brokerB); 42 } 43 44 } 45 | Popular Tags |