Moved PubCompMessage to protocol commons module

broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/ProtocolProcessor.java

@@ -11,7 +11,7 @@ import org.dna.mqtt.moquette.messaging.spi.impl.events.PubAckEvent;
 import org.dna.mqtt.moquette.messaging.spi.impl.events.PublishEvent;
 import org.dna.mqtt.moquette.messaging.spi.impl.subscriptions.Subscription;
 import org.dna.mqtt.moquette.messaging.spi.impl.subscriptions.SubscriptionsStore;
-import org.dna.mqtt.moquette.proto.PubCompMessage;
+import org.dna.mqtt.moquette.proto.messages.PubCompMessage;
 import org.dna.mqtt.moquette.proto.messages.AbstractMessage;
 import org.dna.mqtt.moquette.proto.messages.ConnAckMessage;
 import org.dna.mqtt.moquette.proto.messages.ConnectMessage;

broker/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java

@@ -14,7 +14,7 @@ import org.dna.mqtt.moquette.messaging.spi.IMessaging;
 import org.dna.mqtt.moquette.messaging.spi.IStorageService;
 import org.dna.mqtt.moquette.messaging.spi.impl.events.*;
 import org.dna.mqtt.moquette.messaging.spi.impl.subscriptions.SubscriptionsStore;
-import org.dna.mqtt.moquette.proto.PubCompMessage;
+import org.dna.mqtt.moquette.proto.messages.PubCompMessage;
 import org.dna.mqtt.moquette.proto.messages.*;
 import org.dna.mqtt.moquette.proto.messages.AbstractMessage.QOSType;
 import org.dna.mqtt.moquette.server.ConnectionDescriptor;

broker/src/main/java/org/dna/mqtt/moquette/server/Server.java

@@ -1,5 +1,6 @@
 package org.dna.mqtt.moquette.server;
 
+import org.dna.mqtt.moquette.proto.messages.PubCompMessage;
 import java.io.File;
 import java.io.IOException;
 import java.net.InetSocketAddress;

parser/src/main/java/org/dna/mqtt/moquette/proto/PubCompDecoder.java

@@ -1,5 +1,6 @@
 package org.dna.mqtt.moquette.proto;
 
+import org.dna.mqtt.moquette.proto.messages.PubCompMessage;
 import org.apache.mina.core.buffer.IoBuffer;
 import org.apache.mina.core.session.IoSession;
 import org.apache.mina.filter.codec.demux.MessageDecoderResult;

parser/src/main/java/org/dna/mqtt/moquette/proto/PubCompEncoder.java

@@ -1,5 +1,6 @@
 package org.dna.mqtt.moquette.proto;
 
+import org.dna.mqtt.moquette.proto.messages.PubCompMessage;
 import org.apache.mina.core.buffer.IoBuffer;
 import org.apache.mina.core.session.IoSession;
 import org.apache.mina.filter.codec.ProtocolEncoderOutput;

parser/src/main/java/org/dna/mqtt/moquette/proto/PubCompMessage.java

@@ -1,11 +0,0 @@
-package org.dna.mqtt.moquette.proto;
-
-import org.dna.mqtt.moquette.proto.messages.MessageIDMessage;
-
-/**
- *
- * @author andrea
- */
-public class PubCompMessage extends MessageIDMessage {
-}
-

parser_commons/src/main/java/org/dna/mqtt/moquette/proto/messages/PubCompMessage.java

@@ -0,0 +1,9 @@
+package org.dna.mqtt.moquette.proto.messages;
+
+/**
+ *
+ * @author andrea
+ */
+public class PubCompMessage extends MessageIDMessage {
+}
+