From b6554eb0aceebf891631ba3d6f4dbfb3e2c7a02a Mon Sep 17 00:00:00 2001
From: andrea <selva.andre@gmail.com>
Date: Tue, 18 Aug 2015 23:49:05 +0200
Subject: [PATCH] Added simple main class to test embedding of Broker

---
 .../moquette/server/ConfigurationParser.java  |  2 +-
 embedding_moquette/pom.xml                    | 40 +++++++++++++++++++
 .../testembedded/EmbeddedLauncher.java        | 17 ++++++++
 pom.xml                                       |  1 +
 4 files changed, 59 insertions(+), 1 deletion(-)
 create mode 100644 embedding_moquette/pom.xml
 create mode 100644 embedding_moquette/src/main/java/org/eclipse/moquette/testembedded/EmbeddedLauncher.java

diff --git a/broker/src/main/java/org/eclipse/moquette/server/ConfigurationParser.java b/broker/src/main/java/org/eclipse/moquette/server/ConfigurationParser.java
index 196b3a0f..5e3a8a31 100644
--- a/broker/src/main/java/org/eclipse/moquette/server/ConfigurationParser.java
+++ b/broker/src/main/java/org/eclipse/moquette/server/ConfigurationParser.java
@@ -49,7 +49,7 @@ class ConfigurationParser {
     ConfigurationParser(Properties properties) {
     	this();
     	for (Entry<Object, Object> entrySet : properties.entrySet()) {
-                m_properties.put(entrySet.getKey(), entrySet.getValue());
+            m_properties.put(entrySet.getKey(), entrySet.getValue());
     	}
     }
         
diff --git a/embedding_moquette/pom.xml b/embedding_moquette/pom.xml
new file mode 100644
index 00000000..59650063
--- /dev/null
+++ b/embedding_moquette/pom.xml
@@ -0,0 +1,40 @@
+
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <relativePath>../</relativePath>
+        <!--<relativePath>../pom.xml</relativePath>-->
+        <artifactId>moquette-parent</artifactId>
+        <groupId>org.eclipse.moquette</groupId>
+        <version>${moquette.version}</version>
+    </parent>
+
+    <artifactId>moquette-embedded-test</artifactId>
+    <packaging>jar</packaging>
+    <!--<version>${moquette-version}</version>-->
+    <name>Moquette - Embedded test</name>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.eclipse.moquette</groupId>
+            <artifactId>moquette-broker</artifactId>
+            <version>0.8-SNAPSHOT</version>
+        </dependency>
+
+        <!--<dependency>-->
+            <!--<groupId>org.slf4j</groupId>-->
+            <!--<artifactId>slf4j-log4j12</artifactId>-->
+            <!--<version>1.6.4</version>-->
+        <!--</dependency>-->
+        
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>4.8.2</version>
+            <scope>test</scope>
+        </dependency>
+        
+    </dependencies>
+
+</project>
diff --git a/embedding_moquette/src/main/java/org/eclipse/moquette/testembedded/EmbeddedLauncher.java b/embedding_moquette/src/main/java/org/eclipse/moquette/testembedded/EmbeddedLauncher.java
new file mode 100644
index 00000000..b99801db
--- /dev/null
+++ b/embedding_moquette/src/main/java/org/eclipse/moquette/testembedded/EmbeddedLauncher.java
@@ -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");
+    }
+}
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
index a7db2e06..b2cd7103 100644
--- a/pom.xml
+++ b/pom.xml
@@ -57,6 +57,7 @@
         <module>netty_parser</module>
         <module>broker</module>
         <module>distribution</module>
+        <module>embedding_moquette</module>
     </modules>
     
     <reporting>