1 18 import org.apache.activemq.broker.BrokerService; 19 20 25 public class EmbeddedBroker { 26 public static void main(String [] args) throws Exception { 27 BrokerService broker = new BrokerService(); 28 broker.setUseJmx(true); 29 broker.addConnector("tcp://localhost:61616"); 30 broker.start(); 31 32 Object lock = new Object (); 34 synchronized (lock) { 35 lock.wait(); 36 } 37 } 38 } 39 | Popular Tags |