eclipse-paho / eclipse-paho/paho.mqtt.java

messageArrived() callback fired randomly when there are multiple messages to read?

Open
#697 1 comment 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
2.3k
Forks
919
PR merge metrics
No merged PRs in 30d

Description

Hi, I'm using the library for an IoT application. Can happen that some time an external source publish onto the broker where my application is subscribed something like 100 messages (short messages, < 1kb each) all together, that have to be processed by the app. But if everything works well with the messageArrived() callback when there is a short amount of messages, in this case I see a strange behaviour with timing. In this case I can see the messageArrived() callback fired at a random delay, but it can takes also 3-5second between calls (the link with the broker is quick and stable). After some time it can accelerate for few seconds processing quickly 10/20 messages, than it restart to process messages slowly. What can it be? I'm using paho v.1.2.0 and I'm using a SyncClient with qos 1.
Thanks everybody for help

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.