vertx-mqtt
vertx-mqtt copied to clipboard
Vert.x MQTT
The current API lacks of usability regarding the correlation of operations. NOTE: we are using the _client_ word but it applies to any server endpoint. ### Subscription A single publish...
vertx version: `4.3.1` code: https://github.com/vert-x3/vertx-mqtt/blob/5264cc4d24ccacfa95b8e37b9906726a85958d2e/src/main/java/io/vertx/mqtt/impl/MqttClientImpl.java#L919 `String.format` may be is a performance problem?
Currently it is not possible to control the acknowledgement of an MQTT message, as the client auto-acknowledges messages. ### Version * 3.9.x * 4.1.x ### Context Receiving messages. ### Extra...
Motivation: Multiple MQTT topics can be unsubscribed together. Conformance: Your commits should be signed and you should have signed the Eclipse Contributor Agreement as explained in https://github.com/eclipse/vert.x/blob/master/CONTRIBUTING.md Please also make...
This pull request adds support for `permessage-deflate` compression to the mqtt-server if connected via a websocket. The implementation and configuration is an adjusted version of the implementation in vert.x-core, see...
#### Describe the feature Currently there is an unsubscribe method, which only allows to unsubscribe from a single topic. However, with MQTT you can unsubscribe from multiple topic filters at...
#### module: Vert.x MQTT Do we have plans to implement full support for MQTT5.0? I saw that it was mentioned in the documentation, MQTT5 support is about 90+% complete. I...
#### Describe the feature With #208 it is now possible to access the http headers and the URI that was used by MQTT clients to connect to the MQTT Broker....
### Questions we can use the trafficHandler on netty pipeline,buy it is unvisiable in the mqttserver。 such as: trafficHandler = new GlobalTrafficShapingHandler(xxx); ChannelPipeline pipeline = pipeline(); pipeline.addLast("global-traffic-shaping", trafficHandler); ------- unfortunately,...
### Questions Adding the handler of vertx mqtt will cause the net read / write index of metrics to be unable to be obtained normally. Addlast should be used instead...