Java Hive Client does not receive messages on reconnect

[manojrawat650]

Expected behavior

Hive mqtt client should receive all the messages(that were published to the broker while the consumer was offline) on reconnection with clean_session=false with no session expiry. The client is build in java using hive mqtt client version 1.3.0. The broker is emqx version 4.4.3.

Actual behavior

On reconnection, the client does not receive messages published by the publishers. for example: If publishers sent n messages while client was offline, on reconnection no messages are received.

To Reproduce

Start emqx broker using the below docker command: docker run -d --name emqx -p 1883:1883 -p 8081:8081 -p 8083:8083 -p 8084:8084 -p 8883:8883 -p 18083:18083 emqx/emqx:4.4.3 Start the hive client java application. Client subscribes on qos2. Publishers are publishing on qos1(also tested with qos2).

Steps

Start hivemq client application. Publish messages from 4 different publishers. All messages are received and logged. Now turn off the client application. Publish messages from all the publishers again. Now turn on the client application again. No messages are received.

Reproducer code

Client code: //Create the client Mqtt5AsyncClient subClient = Mqtt5Client.builder().identifier("mqttConsumer") .serverHost("localhost") .serverPort(1883) .automaticReconnect( MqttClientAutoReconnect.builder() .initialDelay(3000, TimeUnit.MILLISECONDS) .maxDelay(10000, TimeUnit.MILLISECONDS).build()) .buildAsync();

//Connect the client subClient.connectWith() .cleanStart(false) .sessionExpiryInterval(3652460*60l) .send() .get(10000, TimeUnit.MILLISECONDS);

//Subscribe to the topic subClient.toAsync() .subscribeWith() .topicFilter("topic1") .qos(MqttQos.EXACTLY_ONCE) .callback(mqtt5Publish -> doSomething(mqtt5Publish)) .send();

//print the received message on callback private static void doSomething(Mqtt5Publish mqtt5Publish) { System.out.println(StandardCharsets.UTF_8.decode(mqtt5Publish.getPayload().get()).toString()); }

Details

• Affected HiveMQ MQTT Client version(s): 1.3.0, 1.2.2
• Used JVM version: 1.8.0_221
• Used OS (name and version): Windows 10
• Used MQTT version: version 5
• Used MQTT broker (name and version): emqx broker 4.4.3