Given public visibility to MQTT Endoer/Decoer constructors to be used from the broker
This commit is contained in:
@@ -17,7 +17,7 @@ public class MQTTDecoder extends ByteToMessageDecoder {
|
||||
|
||||
private Map<Byte, DemuxDecoder> m_decoderMap = new HashMap<Byte, DemuxDecoder>();
|
||||
|
||||
MQTTDecoder() {
|
||||
public MQTTDecoder() {
|
||||
m_decoderMap.put(AbstractMessage.CONNECT, new ConnectDecoder());
|
||||
m_decoderMap.put(AbstractMessage.CONNACK, new ConnAckDecoder());
|
||||
m_decoderMap.put(AbstractMessage.PUBLISH, new PublishDecoder());
|
||||
|
||||
@@ -16,7 +16,7 @@ public class MQTTEncoder extends MessageToByteEncoder<AbstractMessage> {
|
||||
|
||||
private Map<Byte, DemuxEncoder> m_encoderMap = new HashMap<Byte, DemuxEncoder>();
|
||||
|
||||
MQTTEncoder() {
|
||||
public MQTTEncoder() {
|
||||
m_encoderMap.put(AbstractMessage.CONNECT, new ConnectEncoder());
|
||||
m_encoderMap.put(AbstractMessage.CONNACK, new ConnAckEncoder());
|
||||
m_encoderMap.put(AbstractMessage.PUBLISH, new PublishEncoder());
|
||||
|
||||
Reference in New Issue
Block a user