aboutsummaryrefslogtreecommitdiff
path: root/nixpkgs/nixos/modules/services/amqp/activemq/ActiveMQBroker.java
diff options
context:
space:
mode:
Diffstat (limited to 'nixpkgs/nixos/modules/services/amqp/activemq/ActiveMQBroker.java')
-rw-r--r--nixpkgs/nixos/modules/services/amqp/activemq/ActiveMQBroker.java19
1 files changed, 19 insertions, 0 deletions
diff --git a/nixpkgs/nixos/modules/services/amqp/activemq/ActiveMQBroker.java b/nixpkgs/nixos/modules/services/amqp/activemq/ActiveMQBroker.java
new file mode 100644
index 00000000000..c0f5d16ea11
--- /dev/null
+++ b/nixpkgs/nixos/modules/services/amqp/activemq/ActiveMQBroker.java
@@ -0,0 +1,19 @@
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.BrokerFactory;
+import java.net.URI;
+
+public class ActiveMQBroker {
+
+ public static void main(String[] args) throws Throwable {
+ URI uri = new URI((args.length > 0) ? args[0] : "xbean:activemq.xml");
+ BrokerService broker = BrokerFactory.createBroker(uri);
+ broker.start();
+ if (broker.waitUntilStarted()) {
+ broker.waitUntilStopped();
+ } else {
+ System.out.println("Failed starting broker");
+ System.exit(-1);
+ };
+ }
+
+}