简柏林 / thingskit · Commits

Commit e3957ea2aa20b8c59435e6d2b435721e930f0510

Authored by YevhenBondarenko
1 parent 3f9f6efc

MqttTransportHandler improvements

Inline Side-by-side
Showing 1 changed file with 3 additions and 3 deletions
@@ -342,7 +342,7 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement @@ -342,7 +342,7 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement
342 342
343 private MqttMessage createUnSubAckMessage(int msgId) { 343 private MqttMessage createUnSubAckMessage(int msgId) {
344 MqttFixedHeader mqttFixedHeader = 344 MqttFixedHeader mqttFixedHeader =
345 - new MqttFixedHeader(UNSUBACK, false, AT_LEAST_ONCE, false, 0); 345 + new MqttFixedHeader(UNSUBACK, false, AT_MOST_ONCE, false, 0);
346 MqttMessageIdVariableHeader mqttMessageIdVariableHeader = MqttMessageIdVariableHeader.from(msgId); 346 MqttMessageIdVariableHeader mqttMessageIdVariableHeader = MqttMessageIdVariableHeader.from(msgId);
347 return new MqttMessage(mqttFixedHeader, mqttMessageIdVariableHeader); 347 return new MqttMessage(mqttFixedHeader, mqttMessageIdVariableHeader);
348 } 348 }
@@ -445,7 +445,7 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement @@ -445,7 +445,7 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement
445 445
446 private static MqttSubAckMessage createSubAckMessage(Integer msgId, List<Integer> grantedQoSList) { 446 private static MqttSubAckMessage createSubAckMessage(Integer msgId, List<Integer> grantedQoSList) {
447 MqttFixedHeader mqttFixedHeader = 447 MqttFixedHeader mqttFixedHeader =
448 - new MqttFixedHeader(SUBACK, false, AT_LEAST_ONCE, false, 0); 448 + new MqttFixedHeader(SUBACK, false, AT_MOST_ONCE, false, 0);
449 MqttMessageIdVariableHeader mqttMessageIdVariableHeader = MqttMessageIdVariableHeader.from(msgId); 449 MqttMessageIdVariableHeader mqttMessageIdVariableHeader = MqttMessageIdVariableHeader.from(msgId);
450 MqttSubAckPayload mqttSubAckPayload = new MqttSubAckPayload(grantedQoSList); 450 MqttSubAckPayload mqttSubAckPayload = new MqttSubAckPayload(grantedQoSList);
451 return new MqttSubAckMessage(mqttFixedHeader, mqttMessageIdVariableHeader, mqttSubAckPayload); 451 return new MqttSubAckMessage(mqttFixedHeader, mqttMessageIdVariableHeader, mqttSubAckPayload);
@@ -457,7 +457,7 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement @@ -457,7 +457,7 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement
457 457
458 public static MqttPubAckMessage createMqttPubAckMsg(int requestId) { 458 public static MqttPubAckMessage createMqttPubAckMsg(int requestId) {
459 MqttFixedHeader mqttFixedHeader = 459 MqttFixedHeader mqttFixedHeader =
460 - new MqttFixedHeader(PUBACK, false, AT_LEAST_ONCE, false, 0); 460 + new MqttFixedHeader(PUBACK, false, AT_MOST_ONCE, false, 0);
461 MqttMessageIdVariableHeader mqttMsgIdVariableHeader = 461 MqttMessageIdVariableHeader mqttMsgIdVariableHeader =
462 MqttMessageIdVariableHeader.from(requestId); 462 MqttMessageIdVariableHeader.from(requestId);
463 return new MqttPubAckMessage(mqttFixedHeader, mqttMsgIdVariableHeader); 463 return new MqttPubAckMessage(mqttFixedHeader, mqttMsgIdVariableHeader);