HiveMQ MQTT Client - MQTT Client Library Encyclopedia mentions many interesting features, one of them being “Backpressure Handling”, but unfortunately I coudn’t find any code samples or docs. Could someone guide me into the right direction, please.
Best regards, Alex
Hi @ALX ,
Great to see your interest in MQTT and HiveMQ products. Thank you for your question.
Backpressure support in HiveMQ MQTT Client is:
- QoS 1 and 2
- QoS 0 (dropping incoming messages, if necessary)
- Bringing MQTT flow control and reactive pull backpressure together
Bringing MQTT flow control and reactive pull back pressure together is implemented via Reactive Streams, RxJava and Reactor APIs
For a code example please take a look at this example.
I hope this helps,
Thank you for the clarification!