diff --git a/parser/src/test/java/org/dna/mqtt/moquette/proto/ConnectDecoderTest.java b/parser/src/test/java/org/dna/mqtt/moquette/proto/ConnectDecoderTest.java
index 63b8b83a..583aecf6 100644
--- a/parser/src/test/java/org/dna/mqtt/moquette/proto/ConnectDecoderTest.java
+++ b/parser/src/test/java/org/dna/mqtt/moquette/proto/ConnectDecoderTest.java
@@ -152,7 +152,7 @@ public class ConnectDecoderTest {
     }
     
     /**
-     * Encode and insert the given stirng into the given buff
+     * Encode and insert the given string into the given buff
      */
     private IoBuffer encodeString(IoBuffer buff, String str) throws UnsupportedEncodingException {
         buff.put(Utils.encodeString(str));
diff --git a/parser/src/test/java/org/dna/mqtt/moquette/proto/TestUtils.java b/parser/src/test/java/org/dna/mqtt/moquette/proto/TestUtils.java
index fb4bb602..78e34225 100644
--- a/parser/src/test/java/org/dna/mqtt/moquette/proto/TestUtils.java
+++ b/parser/src/test/java/org/dna/mqtt/moquette/proto/TestUtils.java
@@ -79,7 +79,7 @@ public class TestUtils {
     }
     
     /**
-     * Verify that the given bytes buffer og the given numBytes length is present
+     * Verify that the given bytes buffer of the given numBytes length is present
      * in the buff starting from the current position.
      */
     static void verifyBuff(int numBytes, byte[] bytes, IoBuffer buff) {
diff --git a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/ConnectMessage.java b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/ConnectMessage.java
index f286d682..123041c7 100644
--- a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/ConnectMessage.java
+++ b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/ConnectMessage.java
@@ -24,6 +24,10 @@ public class ConnectMessage extends AbstractMessage {
     String m_clientID;
     String m_willtopic;
     String m_willMessage;
+    
+    public ConnectMessage() {
+        m_messageType = AbstractMessage.CONNECT;
+    }
 
     public boolean isCleanSession() {
         return m_cleanSession;
diff --git a/pom.xml b/pom.xml
index a9a4e809..0c2343a3 100644
--- a/pom.xml
+++ b/pom.xml
@@ -21,7 +21,6 @@
         <module>netty_parser</module>
         <module>broker</module>
         <module>benchmarking</module>
-        <module>parser_commons</module>
     </modules>
 
 </project>