Added message type to every message

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;

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;
+    }
 }

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;
+    }
 }

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;
+    }
 }

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;
+    }
 }

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;
+    }
 }
 

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;
+    }
 }

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;
+    }
 }

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;

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;

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;
     }
     

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;
+    }
 }
 

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;