1 18 package org.apache.activemq.broker.util; 19 20 import org.apache.activemq.broker.BrokerFactory; 21 import org.apache.activemq.broker.BrokerService; 22 import org.apache.activemq.test.JmsTopicSendReceiveTest; 23 import org.apache.commons.logging.Log; 24 import org.apache.commons.logging.LogFactory; 25 26 import java.net.URI ; 27 28 32 public class LoggingBrokerTest extends JmsTopicSendReceiveTest { 33 private static final Log log = LogFactory.getLog(LoggingBrokerTest.class); 34 private BrokerService broker; 35 36 protected void setUp() throws Exception { 37 broker = createBroker(); 38 super.setUp(); 39 } 40 41 protected void tearDown() throws Exception { 42 super.tearDown(); 43 if (broker != null) { 44 broker.stop(); 45 } 46 } 47 48 protected BrokerService createBroker() throws Exception { 49 return createBroker("org/apache/activemq/util/logging-broker.xml"); 50 } 51 52 protected BrokerService createBroker(String uri) throws Exception { 53 log.info("Loading broker configuration from the classpath with URI: " + uri); 54 return BrokerFactory.createBroker(new URI ("xbean:" + uri)); 55 } 56 } 57 | Popular Tags |