eclipse-paho / eclipse-paho/paho.mqtt.java
messageArrived() callback fired randomly when there are multiple messages to read?
- 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
Assessment
This issue has not been assessed yet.