a9863f8128
Motivation: When the MqttDecoder decodes a message larger than the 'maxBytesInMessage' a DecoderException is thrown and a MqttMessage with just the failure cause is returned. Even if I can't handle the message, I might want to send an ACK so that I won't have to worry about it again. Modification: The DecoderException is thrown after the variableHeader is decoded. The fixed and variable headers are then added to the MqttMessage along with the failure cause. Result: The invalid MqttMessage will have headers if available. |
||
---|---|---|
.. | ||
MqttCodecUtil.java | ||
MqttConnAckMessage.java | ||
MqttConnAckVariableHeader.java | ||
MqttConnectMessage.java | ||
MqttConnectPayload.java | ||
MqttConnectReturnCode.java | ||
MqttConnectVariableHeader.java | ||
MqttDecoder.java | ||
MqttEncoder.java | ||
MqttFixedHeader.java | ||
MqttIdentifierRejectedException.java | ||
MqttMessage.java | ||
MqttMessageBuilders.java | ||
MqttMessageFactory.java | ||
MqttMessageIdVariableHeader.java | ||
MqttMessageType.java | ||
MqttPubAckMessage.java | ||
MqttPublishMessage.java | ||
MqttPublishVariableHeader.java | ||
MqttQoS.java | ||
MqttSubAckMessage.java | ||
MqttSubAckPayload.java | ||
MqttSubscribeMessage.java | ||
MqttSubscribePayload.java | ||
MqttTopicSubscription.java | ||
MqttUnacceptableProtocolVersionException.java | ||
MqttUnsubAckMessage.java | ||
MqttUnsubscribeMessage.java | ||
MqttUnsubscribePayload.java | ||
MqttVersion.java | ||
package-info.java |