Receiver.java
// for send message to lower buffer
public ByteBuffer parseMessage(String protocol, Message message) {
if (MQTT.equalsIgnoreCase(protocol)) {
return MqttMessageIO.parseServerSending((MqttMessage) message,
(ByteBuffer) message.body);
} else {
return MessageIO.parseServerSending(message,
(ByteBuffer) message.body);
}
}
the convert should move to MqttMessageIO
Receiver.java
the convert should move to MqttMessageIO