Fork MqttClientImpl to fix vert-x3/vertx-mqtt#109

This change forks the MqttClientImpl from vertx-mqtt, since the connection handling is broken again.
ctron · Mar 19, 2019 · bdf1029 · bdf1029
1 parent dd4d8f3
commit bdf1029
Show file tree

Hide file tree

Showing 2 changed files with 1,053 additions and 1 deletion.
diff --git a/simulator-mqtt/src/main/java/de/dentrassi/hono/simulator/mqtt/Device.java b/simulator-mqtt/src/main/java/de/dentrassi/hono/simulator/mqtt/Device.java
@@ -18,6 +18,7 @@
 import de.dentrassi.hono.demo.common.Payload;
 import de.dentrassi.hono.demo.common.Register;
 import de.dentrassi.hono.demo.common.Tls;
+import de.dentrassi.hono.simulator.mqtt.vertx.MqttClientImpl;
 import io.glutamate.lang.Environment;
 import io.netty.handler.codec.mqtt.MqttConnectReturnCode;
 import io.netty.handler.codec.mqtt.MqttQoS;
@@ -93,7 +94,7 @@ public Device(final Vertx vertx, final String username, final String deviceId, f
         options.setUsername(username + "@" + tenant);
         options.setPassword(password);
 
-        this.client = MqttClient.create(vertx, options);
+        this.client = new MqttClientImpl(vertx, options);
 
         this.client.publishCompletionHandler(this::publishComplete);
         this.client.closeHandler(v -> connectionLost(null));