MQTT protocol defines Session Present Flag as follows:

ConnectHandler writes ConnAck having session-present=false constantly:
See:
|
channel.writeAndFlush(mqttConnAckMessage); |
|
public static MqttConnAckMessage buildConnAckMessage(MqttConnectReturnCode returnCode) { |
MQTT protocol defines Session Present Flag as follows:

ConnectHandler writes ConnAck having session-present=false constantly:
See:
rocketmq-mqtt/mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttConnectHandler.java
Line 109 in 477d478
rocketmq-mqtt/mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/facotry/MqttMessageFactory.java
Line 42 in 477d478