Update mqtt examples to latest API changes

Author: vietj

mqtt-examples/src/main/java/io/vertx/example/mqtt/app/Client.java

@@ -43,10 +43,7 @@ public static void main(String[] args) {
 
   @Override
   public void start() throws Exception {
-    MqttClientOptions options = new MqttClientOptions()
-      .setPort(BROKER_PORT)
-      .setHost(BROKER_HOST)
-      .setKeepAliveTimeSeconds(2);
+    MqttClientOptions options = new MqttClientOptions().setKeepAliveTimeSeconds(2);
 
     MqttClient client = MqttClient.create(Vertx.vertx(), options);
 
@@ -57,7 +54,7 @@ public void start() throws Exception {
     });
 
     // handle response on subscribe request
-    client.subscribeCompleteHandler(h -> {
+    client.subscribeCompletionHandler(h -> {
       System.out.println("Receive SUBACK from server with granted QoS : " + h.grantedQoSLevels());
 
       // let's publish a message to the subscribed topic
@@ -74,7 +71,7 @@ public void start() throws Exception {
     });
 
     // handle response on unsubscribe request
-    client.unsubscribeCompleteHandler(h -> {
+    client.unsubscribeCompletionHandler(h -> {
       System.out.println("Receive UNSUBACK from server");
       vertx.setTimer(5000, l ->
         // disconnect for server
@@ -83,7 +80,7 @@ public void start() throws Exception {
     });
 
     // connect to a server
-    client.connect(ch -> {
+    client.connect(BROKER_PORT, BROKER_HOST, ch -> {
       if (ch.succeeded()) {
         System.out.println("Connected to a server");
         client.subscribe(MQTT_TOPIC, 0);

mqtt-examples/src/main/java/io/vertx/example/mqtt/app/Server.java

@@ -87,7 +87,7 @@ public void start() throws Exception {
 
             endpoint.publishRelease(messageId);
 
-          }).publishCompleteHandler(messageId -> {
+          }).publishCompletionHandler(messageId -> {
 
             System.out.println("Received ack for message = " + messageId);
           });

mqtt-examples/src/main/java/io/vertx/example/mqtt/simple/Client.java

@@ -21,7 +21,6 @@
 import io.vertx.core.buffer.Buffer;
 import io.vertx.example.mqtt.util.Runner;
 import io.vertx.mqtt.MqttClient;
-import io.vertx.mqtt.MqttClientOptions;
 
 /**
  * An example of using the MQTT client as a verticle
@@ -40,13 +39,9 @@ public static void main(String[] args) {
 
   @Override
   public void start() throws Exception {
-    MqttClientOptions options = new MqttClientOptions()
-      .setPort(BROKER_PORT)
-      .setHost(BROKER_HOST);
+    MqttClient mqttClient = MqttClient.create(vertx);
 
-    MqttClient mqttClient = MqttClient.create(vertx, options);
-
-    mqttClient.connect(ch -> {
+    mqttClient.connect(BROKER_PORT, BROKER_HOST, ch -> {
       if (ch.succeeded()) {
         System.out.println("Connected to a server");
 

mqtt-examples/src/main/java/io/vertx/example/mqtt/ssl/Client.java

@@ -22,14 +22,12 @@ public static void main(String[] args) {
   @Override
   public void start() throws Exception {
     MqttClientOptions options = new MqttClientOptions();
-      options.setPort(BROKER_PORT);
-      options.setHost(BROKER_HOST);
       options.setSsl(true);
       options.setTrustAll(true);
 
     MqttClient mqttClient = MqttClient.create(vertx, options);
 
-    mqttClient.connect(ch -> {
+    mqttClient.connect(BROKER_PORT, BROKER_HOST, ch -> {
       if (ch.succeeded()) {
         System.out.println("Connected to a server");