hivemq-mqtt-client
hivemq-mqtt-client copied to clipboard
hivemq
HiveMQ MQTT Client is an MQTT 5.0 and MQTT 3.1.1 compatible and feature-rich high-performance Java client library with different API flavours and backpressure support
Are there any plans in implementing an interface to expose the methods via Kotlin coroutines and Flows? The reactive API is great but for Android or KMP users, using coroutines...
## Expected behavior Hive mqtt client should receive all the messages(that were published to the broker while the consumer was offline) on reconnection with clean_session=false with no session expiry. The...
## Expected behavior Hive mqtt client should receive all the messages(that were published to the broker while the consumer was offline) on reconnection with clean_session=false with no session expiry. The...
Hello, We are facing what we think to be an issue. Here is the scenario : - Subscribe is set with a callback, an auto reconnect and the manual ack...
## Expected behavior No Vulnerability should be found in used libraries. ## Actual behavior Below vulnerabilities found Severity | | Vulnerability Id | CVSS 3 Score | CVSS 2 Score...
## Expected behavior Connecting a client with reconnect configured should throw if it can't connect initially. ## Actual behavior It blocks infinitely ## To Reproduce ### Reproducer code `Mqtt5Client.builder().serverHost("hostWithoutRunningBroker").automaticReconnectWithDefaultConfig().toBlocking().connect(...)` ##...
case step1: publisher send 1,2,3,4,5 (total 5 messages) subscriber received 1,2,3,4,5 (total 5 messages) step2: and then I close the program of the broker and wait for a while. step3:...
**Motivation** Added the option to add custom http headers (eg bearer token authentication to reverse proxy) for websocket connection **Changes** MqttWebSocketConfig
## Problem or use case MQTT messages that are sent via the HiveMQ client library (here, reactive API via Mqtt5RxClient.publish(Flowable), Android) are buffered if the client is not connected to...
## Problem or use case It appears the intention of `MqttUtf8String.toString()` is to return the decoded String (see also [implementation](https://github.com/hivemq/hivemq-mqtt-client/blob/2bdff6596374c76d8a5503a5c2a66e3684a11cac/src/main/java/com/hivemq/client/internal/mqtt/datatypes/MqttUtf8StringImpl.java#L309)). However, this is currently not documented; `toString()` is not overridden...
