From 466e0946d607adf68cc20da72a463725b3cf4a0b Mon Sep 17 00:00:00 2001 From: andrea Date: Sat, 14 Sep 2013 15:06:19 +0200 Subject: [PATCH] Given public visibility to MQTT Endoer/Decoer constructors to be used from the broker --- .../java/org/dna/mqtt/moquette/parser/netty/MQTTDecoder.java | 2 +- .../java/org/dna/mqtt/moquette/parser/netty/MQTTEncoder.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/netty_parser/src/main/java/org/dna/mqtt/moquette/parser/netty/MQTTDecoder.java b/netty_parser/src/main/java/org/dna/mqtt/moquette/parser/netty/MQTTDecoder.java index 645a2105..35676e2f 100644 --- a/netty_parser/src/main/java/org/dna/mqtt/moquette/parser/netty/MQTTDecoder.java +++ b/netty_parser/src/main/java/org/dna/mqtt/moquette/parser/netty/MQTTDecoder.java @@ -17,7 +17,7 @@ public class MQTTDecoder extends ByteToMessageDecoder { private Map m_decoderMap = new HashMap(); - MQTTDecoder() { + public MQTTDecoder() { m_decoderMap.put(AbstractMessage.CONNECT, new ConnectDecoder()); m_decoderMap.put(AbstractMessage.CONNACK, new ConnAckDecoder()); m_decoderMap.put(AbstractMessage.PUBLISH, new PublishDecoder()); diff --git a/netty_parser/src/main/java/org/dna/mqtt/moquette/parser/netty/MQTTEncoder.java b/netty_parser/src/main/java/org/dna/mqtt/moquette/parser/netty/MQTTEncoder.java index d2585b19..0b9eabbe 100644 --- a/netty_parser/src/main/java/org/dna/mqtt/moquette/parser/netty/MQTTEncoder.java +++ b/netty_parser/src/main/java/org/dna/mqtt/moquette/parser/netty/MQTTEncoder.java @@ -16,7 +16,7 @@ public class MQTTEncoder extends MessageToByteEncoder { private Map m_encoderMap = new HashMap(); - MQTTEncoder() { + public MQTTEncoder() { m_encoderMap.put(AbstractMessage.CONNECT, new ConnectEncoder()); m_encoderMap.put(AbstractMessage.CONNACK, new ConnAckEncoder()); m_encoderMap.put(AbstractMessage.PUBLISH, new PublishEncoder());