Added simple main class to test embedding of Broker

2015-08-18 23:59:45 +02:00
parent fdbee3a21f
commit b6554eb0ac
4 changed files with 59 additions and 1 deletions
@@ -0,0 +1,17 @@
+package org.eclipse.moquette.testembedded;
+
+import org.eclipse.moquette.server.Server;
+
+import java.io.IOException;
+
+public class EmbeddedLauncher {
+    public static void main(String[] args) throws InterruptedException, IOException {
+        final Server mqttBroker = new Server();
+        mqttBroker.startServer();
+        System.out.println("Broker started");
+        Thread.sleep(1000);
+        System.out.println("Stopping broker");
+        mqttBroker.stopServer();
+        System.out.println("Broker stopped");
+    }
+}