Backpressure Handling

HiveMQ Client Library
1

Hi all,

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

2

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,
Kind regards,
Dasha

3

Thank you for the clarification!