Skip to content

Commit 5c7e96f

Browse files
committed
Added better comments in MqttIncomingQosHandler.ack
1 parent e1e40a6 commit 5c7e96f

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/main/java/com/hivemq/client/internal/mqtt/handler/publish/incoming/MqttIncomingQosHandler.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -212,10 +212,11 @@ private boolean ack(
212212

213213
final Object prevMessage = messages.put(pubAckOrRec);
214214
if (prevMessage != publishWithFlows) {
215-
// message has been overwritten by a new message because session state on server differs
216215
if (prevMessage == null) {
216+
// session has expired in the meantime
217217
messages.remove(pubAckOrRec.getPacketIdentifier());
218218
} else {
219+
// message has been overwritten by a new message because session state on server differs
219220
messages.put(prevMessage);
220221
}
221222
return false;

0 commit comments

Comments
 (0)