nixos/modules/services/amqp/activemq/ActiveMQBroker.java

   1 import org.apache.activemq.broker.BrokerService;
   2 import org.apache.activemq.broker.BrokerFactory;
   3 import java.net.URI;
   4
   5 public 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 }