1 18 package org.apache.activemq.test; 19 20 import org.apache.activemq.ActiveMQConnectionFactory; 21 import org.apache.activemq.broker.BrokerService; 22 23 26 public class JmsTopicSendReceiveWithTwoConnectionsAndEmbeddedBrokerTest extends JmsTopicSendReceiveWithTwoConnectionsTest { 27 28 protected BrokerService broker; 29 protected String bindAddress = "tcp://localhost:61616"; 30 31 36 protected void setUp() throws Exception { 37 if (broker == null) { 38 broker = createBroker(); 39 } 40 super.setUp(); 41 } 42 43 protected void tearDown() throws Exception { 44 super.tearDown(); 45 46 if (broker != null) { 47 broker.stop(); 48 } 49 } 50 51 56 protected BrokerService createBroker() throws Exception { 57 BrokerService answer = new BrokerService(); 58 configureBroker(answer); 59 answer.start(); 60 return answer; 61 } 62 63 protected void configureBroker(BrokerService answer) throws Exception { 64 answer.addConnector(bindAddress); 65 } 66 67 protected ActiveMQConnectionFactory createConnectionFactory() throws Exception { 68 return new ActiveMQConnectionFactory(bindAddress); 69 } 70 } 71 | Popular Tags |