From ce7bf469f3721c1865e4a0639921e93dfb57e972 Mon Sep 17 00:00:00 2001 From: andrea Date: Sun, 26 Aug 2012 13:38:42 +0200 Subject: [PATCH] Minor change, fixed imports --- .../main/java/org/dna/mqtt/moquette/proto/PublishDecoder.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/parser/src/main/java/org/dna/mqtt/moquette/proto/PublishDecoder.java b/parser/src/main/java/org/dna/mqtt/moquette/proto/PublishDecoder.java index c8ec8b42..f98aa81d 100644 --- a/parser/src/main/java/org/dna/mqtt/moquette/proto/PublishDecoder.java +++ b/parser/src/main/java/org/dna/mqtt/moquette/proto/PublishDecoder.java @@ -5,8 +5,8 @@ import org.apache.mina.core.session.IoSession; import org.apache.mina.filter.codec.ProtocolDecoderOutput; import org.apache.mina.filter.codec.demux.MessageDecoderResult; import org.dna.mqtt.moquette.proto.messages.AbstractMessage; +import org.dna.mqtt.moquette.proto.messages.AbstractMessage.QOSType; import org.dna.mqtt.moquette.proto.messages.PublishMessage; -import static org.dna.mqtt.moquette.proto.messages.AbstractMessage.*; /** * @@ -20,7 +20,7 @@ public class PublishDecoder extends MqttDecoder { public MessageDecoderResult decode(IoSession session, IoBuffer in, ProtocolDecoderOutput out) throws Exception { int startPos = in.position(); - + //Common decoding part PublishMessage message = new PublishMessage(); if (decodeCommonHeader(message, in) == NEED_DATA) {