1 17 package org.apache.servicemix.eip; 18 19 import org.apache.activemq.broker.BrokerService; 20 21 22 public class WireTapJmsFlowTest extends WireTapTest { 23 24 protected BrokerService broker; 25 26 protected void setUp() throws Exception { 27 broker = new BrokerService(); 28 broker.setPersistent(false); 29 broker.addConnector("tcp://localhost:61616"); 30 broker.start(); 31 32 super.setUp(); 33 } 34 35 protected void tearDown() throws Exception { 36 super.tearDown(); 37 broker.stop(); 38 } 39 40 protected void configureContainer() throws Exception { 41 jbi.setFlowName("jms?jmsURL=tcp://localhost:61616"); 42 } 43 44 } 45 | Popular Tags |