pyrox.dev
1import org.apache.activemq.broker.BrokerService;
2import org.apache.activemq.broker.BrokerFactory;
3import java.net.URI;
4
5public class ActiveMQBroker {
6
7 public static void main(String[] args) throws Throwable {
8 URI uri = new URI((args.length > 0) ? args[0] : "xbean:activemq.xml");
9 BrokerService broker = BrokerFactory.createBroker(uri);
10 broker.start();
11 if (broker.waitUntilStarted()) {
12 broker.waitUntilStopped();
13 } else {
14 System.out.println("Failed starting broker");
15 System.exit(-1);
16 };
17 }
18
19}