@@ -37,7 +37,7 @@ public V5Client() throws InterruptedException {
3737 MqttConnectionOptionsBuilder conOptsBuilder = new MqttConnectionOptionsBuilder ();
3838 MqttConnectionOptions conOpts = conOptsBuilder .serverURI (broker ).cleanSession (true )
3939 .sessionExpiryInterval (120 ).automaticReconnect (true )
40- .will (topic , new MqttMessage (willContent .getBytes (), qos , false , null )).topicAliasMaximum (1000 ).build ();
40+ .will (topic , new MqttMessage (willContent .getBytes (), qos , false )).topicAliasMaximum (1000 ).build ();
4141 asyncClient .setCallback (this );
4242
4343
@@ -83,7 +83,7 @@ public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
8383 message = "FINISH" ;
8484 running = false ;
8585 }
86- asyncClient .publish (topic , new MqttMessage (message .getBytes (), 2 , false , null ));
86+ asyncClient .publish (topic , new MqttMessage (message .getBytes (), 2 , false ));
8787 x ++;
8888
8989 }
@@ -139,17 +139,6 @@ public void mqttErrorOccured(MqttException exception) {
139139 // TODO Auto-generated method stub
140140
141141 }
142-
143- @ Override
144- public void connectComplete (boolean reconnect , String serverURI ) {
145- // TODO Auto-generated method stub
146-
147- }
148-
149- @ Override
150- public void authPacketArrived (int reasonCode , MqttProperties properties ) {
151- // TODO Auto-generated method stub
152-
153- }
142+
154143
155144}
0 commit comments