Skip to content

Does the paho client have a buffering mechanism when lot's of message arrived with high concurrency in subscription ? #1075

Open
@killerqi520

Description

@killerqi520

We use a broker (Mosquitto 1.4.11) and use mqtt v3。Our java application introduced paho(version 1.2.5) and subscribed to a topic using callback(MqttCallback.messageArrived()) to receive mqtt v3 messages. When another program published a large number of messages to this topic with high concurrency, then istopped sending. We found that the paho client in our application seemed to be blocked, and the application did not receive all the messages through subscription just part of messages. When any message was published to the topic again, our application could receive the messages that were not received before. Does the paho client have a buffering mechanism? Can this function be turned off? It feels like a bug.

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions