Messages are once they are flushed to network buffer, which does not respect MQTT QoS.
For QoS = 1, 2, messages should be acked on receipt of PubAck and PUBCOMP respectively.
|
} else if (subscription.isShare()) { |
|
String lmqTopic = MixAll.LMQ_PREFIX + StringUtils.replace(message.getOriginTopic(), "/","%"); |
|
lmqQueueStore.popAck(lmqTopic, subscription.getSharedName(), message); |
|
} |
Messages are once they are flushed to network buffer, which does not respect MQTT QoS.
For QoS = 1, 2, messages should be acked on receipt of PubAck and PUBCOMP respectively.
rocketmq-mqtt/mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/PushAction.java
Lines 170 to 173 in 7b556f9