vertx-mqtt
vertx-mqtt copied to clipboard
vert-x3
Vert.x MQTT
When The NetServerOptions set the ' IdleTimeout'. The connection will add the name 'idle' handler before. And the mqttserver will add the same name handler too.
fixed #85 require an messageId and send message with it, when get ack from remote client , will kown the message is success. if no ack for a long time...
| SSL FALSE | False instance Count | SSL TRUE | True instance Count -- | -- | -- | -- | -- int[] | 213 MB | | 748...
MQTT doesn't have flow control but back-pressure support can be added at TCP level (as Vert.x websocket implementation)
Currently the implementation handles differently QoS 1 and 2 differently on the client and server - the server will simply dispatch messages to the handlers and let the application be...
According to the MQTT Spec section 3.1.4 (http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/errata01/os/mqtt-v3.1.1-errata01-os-complete.html#_Toc442180845): "Clients are allowed to send further Control Packets immediately after sending a CONNECT Packet; Clients need not wait for a CONNACK Packet...
Vertx-MQTT version 3.6.2 Currently the general pattern for this client is to send all of the acknowledgements prior to the invocation of the registered publish handler. Unfortunately this means that...
What is your opinion on adding a Router for handling MQTT messages from clients? Something very similar to the Vert.X Web Router. Potential usage: ``` MqttServer mqttServer = MqttServer.create(vertx, options);...
The keep alive does not seem to work, maybe i also found out why it is so. Reproduce: 1. Connect to any remote mqtt-broker (not on your pc). 2. unplug...
Hi all, I use the vertx-mqtt Version: **3.6.2** I have a vertical worker which contains the MQTT-Server: ``` public class StrangeMQTTServer extends AbstractVerticle { private MqttServer mqttServer; @Override public void...
