set mqtt sub sync

.idea/.name

+REST_MQTT_example
\ No newline at end of file

.idea/gradle.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
+  <component name="GradleMigrationSettings" migrationVersion="1" />
   <component name="GradleSettings">
     <option name="linkedExternalProjectsSettings">
       <GradleProjectSettings>

build/tmp/compileJava/source-classes-mapping.txt

-REST/beans/Users.java
- REST.beans.Users
-REST/StartServer.java
- REST.StartServer
 REST/beans/User.java
  REST.beans.User
 REST/services/HelloWorld.java
  REST.services.HelloWorld
 REST/services/UsersService.java
  REST.services.UsersService
+REST/StartServer.java
+ REST.StartServer
+REST/beans/Users.java
+ REST.beans.Users
 MQTT/PubExample.java
- PubExample
+ MQTT.PubExample
 MQTT/SubExample.java
- SubExample
- SubExample$1
+ MQTT.SubExample
+ MQTT.SubExample$1

src/main/java/MQTT/SubExample.java

@@ -18,14 +18,13 @@ public class SubExample {
 
         try {
             // Create an Mqtt client
-            MqttAsyncClient mqttClient = new MqttAsyncClient(broker, clientId);
+            MqttClient mqttClient = new MqttClient(broker, clientId);
             MqttConnectOptions connOpts = new MqttConnectOptions();
             connOpts.setCleanSession(true);
 
             // Connect the client
             System.out.println(clientId + " Connecting to " + broker);
-            IMqttToken token = mqttClient.connect(connOpts);
-            token.waitForCompletion();
+            mqttClient.connect(connOpts);
             System.out.println(clientId + " Connected");