|
|
|
@ -247,7 +247,7 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement |
|
|
|
|
|
|
|
private MqttMessage createUnSubAckMessage(int msgId) { |
|
|
|
MqttFixedHeader mqttFixedHeader = |
|
|
|
new MqttFixedHeader(SUBACK, false, AT_LEAST_ONCE, false, 0); |
|
|
|
new MqttFixedHeader(UNSUBACK, false, AT_LEAST_ONCE, false, 0); |
|
|
|
MqttMessageIdVariableHeader mqttMessageIdVariableHeader = MqttMessageIdVariableHeader.from(msgId); |
|
|
|
return new MqttMessage(mqttFixedHeader, mqttMessageIdVariableHeader); |
|
|
|
} |
|
|
|
|