diff --git a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/ConnAckMessage.java b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/ConnAckMessage.java
index 9d8d4a7f..8102b534 100644
--- a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/ConnAckMessage.java
+++ b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/ConnAckMessage.java
@@ -14,6 +14,10 @@ public class ConnAckMessage extends AbstractMessage {
     public static final byte NOT_AUTHORIZED = 0x05;
     
     private byte m_returnCode;
+    
+    public ConnAckMessage() {
+        m_messageType = AbstractMessage.CONNACK;
+    }
 
     public byte getReturnCode() {
         return m_returnCode;
diff --git a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/DisconnectMessage.java b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/DisconnectMessage.java
index 12c4f179..df1c998a 100644
--- a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/DisconnectMessage.java
+++ b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/DisconnectMessage.java
@@ -6,4 +6,8 @@ package org.dna.mqtt.moquette.proto.messages;
  * @author andrea
  */
 public class DisconnectMessage extends ZeroLengthMessage {
+    
+    public DisconnectMessage() {
+        m_messageType = AbstractMessage.DISCONNECT;
+    }
 }
diff --git a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PingReqMessage.java b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PingReqMessage.java
index 4bd1f1ba..672187d0 100644
--- a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PingReqMessage.java
+++ b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PingReqMessage.java
@@ -6,4 +6,8 @@ package org.dna.mqtt.moquette.proto.messages;
  * @author andrea
  */
 public class PingReqMessage extends ZeroLengthMessage {
+    
+    public PingReqMessage() {
+        m_messageType = AbstractMessage.PINGREQ;
+    }
 }
diff --git a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PingRespMessage.java b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PingRespMessage.java
index aad82e57..4f876ed5 100644
--- a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PingRespMessage.java
+++ b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PingRespMessage.java
@@ -5,4 +5,8 @@ package org.dna.mqtt.moquette.proto.messages;
  * @author andrea
  */
 public class PingRespMessage extends ZeroLengthMessage {
+    
+    public PingRespMessage() {
+        m_messageType = AbstractMessage.PINGRESP;
+    }
 }
diff --git a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PubAckMessage.java b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PubAckMessage.java
index 5c0a87e7..67448532 100644
--- a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PubAckMessage.java
+++ b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PubAckMessage.java
@@ -6,4 +6,8 @@ package org.dna.mqtt.moquette.proto.messages;
  * @author andrea
  */
 public class PubAckMessage extends MessageIDMessage {
+    
+    public PubAckMessage() {
+        m_messageType = AbstractMessage.PUBACK;
+    }
 }
diff --git a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PubCompMessage.java b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PubCompMessage.java
index a4dbdff5..c28314ba 100644
--- a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PubCompMessage.java
+++ b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PubCompMessage.java
@@ -5,5 +5,9 @@ package org.dna.mqtt.moquette.proto.messages;
  * @author andrea
  */
 public class PubCompMessage extends MessageIDMessage {
+    
+    public PubCompMessage() {
+        m_messageType = AbstractMessage.PUBCOMP;
+    }
 }
 
diff --git a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PubRecMessage.java b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PubRecMessage.java
index 648e6e42..d2b41123 100644
--- a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PubRecMessage.java
+++ b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PubRecMessage.java
@@ -7,4 +7,7 @@ package org.dna.mqtt.moquette.proto.messages;
  */
 public class PubRecMessage extends MessageIDMessage {
     
+    public PubRecMessage() {
+        m_messageType = AbstractMessage.PUBREC;
+    }
 }
diff --git a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PubRelMessage.java b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PubRelMessage.java
index aef4a5bd..5bbd29a9 100644
--- a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PubRelMessage.java
+++ b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PubRelMessage.java
@@ -5,4 +5,8 @@ package org.dna.mqtt.moquette.proto.messages;
  * @author andrea
  */
 public class PubRelMessage extends MessageIDMessage {
+    
+    public PubRelMessage() {
+        m_messageType = AbstractMessage.PUBREL;
+    }
 }
diff --git a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PublishMessage.java b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PublishMessage.java
index 41742e2a..67a5da3f 100644
--- a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PublishMessage.java
+++ b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PublishMessage.java
@@ -17,6 +17,10 @@ public class PublishMessage extends MessageIDMessage {
     public void setMessageID(Integer messageID) {
         this.m_messageID = messageID;
     }*/
+    
+    public PublishMessage() {
+        m_messageType = AbstractMessage.PUBLISH;
+    }
 
     public String getTopicName() {
         return m_topicName;
diff --git a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/SubAckMessage.java b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/SubAckMessage.java
index debe6247..d4ea6316 100644
--- a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/SubAckMessage.java
+++ b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/SubAckMessage.java
@@ -10,6 +10,10 @@ import java.util.List;
 public class SubAckMessage extends MessageIDMessage {
 
     List<QOSType> m_types = new ArrayList<QOSType>();
+    
+    public SubAckMessage() {
+        m_messageType = AbstractMessage.SUBACK;
+    }
 
     public List<QOSType> types() {
         return m_types;
diff --git a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/SubscribeMessage.java b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/SubscribeMessage.java
index d93a52eb..67accee3 100644
--- a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/SubscribeMessage.java
+++ b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/SubscribeMessage.java
@@ -31,6 +31,7 @@ public class SubscribeMessage extends MessageIDMessage {
 
     public SubscribeMessage() {
         //Subscribe has always QoS 1
+        m_messageType = AbstractMessage.SUBSCRIBE;
         m_qos = AbstractMessage.QOSType.LEAST_ONE;
     }
     
diff --git a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/UnsubAckMessage.java b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/UnsubAckMessage.java
index e5f92f6d..75bfd98e 100644
--- a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/UnsubAckMessage.java
+++ b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/UnsubAckMessage.java
@@ -5,5 +5,9 @@ package org.dna.mqtt.moquette.proto.messages;
  * @author andrea
  */
 public class UnsubAckMessage extends MessageIDMessage {
+    
+    public UnsubAckMessage() {
+        m_messageType = AbstractMessage.UNSUBACK;
+    }
 }
 
diff --git a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/UnsubscribeMessage.java b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/UnsubscribeMessage.java
index 1d3912db..a1befe17 100644
--- a/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/UnsubscribeMessage.java
+++ b/parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/UnsubscribeMessage.java
@@ -9,6 +9,10 @@ import java.util.List;
  */
 public class UnsubscribeMessage extends MessageIDMessage {
     List<String> m_types = new ArrayList<String>();
+    
+    public UnsubscribeMessage() {
+        m_messageType = AbstractMessage.UNSUBSCRIBE;
+    }
 
     public List<String> topics() {
         return m_types;