2 files changed, 4 insertions, 4 deletions
diff --git a/tools/pub.c b/tools/pub.c
index f2107ae..6044ec3 100644
--- a/tools/pub.c
+++ b/tools/pub.c
@@ -111,13 +111,13 @@ int main(int argc, char **argv)
 
     parse_args(&options, argc, argv);
 
-    client = MqttClientNew(options.client_id, 1);
+    client = MqttClientNew(options.client_id);
 
     MqttClientSetOnConnect(client, onConnect);
     MqttClientSetOnPublish(client, onPublish);
     MqttClientSetUserData(client, &options);
 
-    MqttClientConnect(client, "test.mosquitto.org", 1883, 60);
+    MqttClientConnect(client, "test.mosquitto.org", 1883, 60, 1);
 
     MqttClientRun(client);
 
diff --git a/tools/sub.c b/tools/sub.c
index ffaf2a2..b556a27 100644
--- a/tools/sub.c
+++ b/tools/sub.c
@@ -110,14 +110,14 @@ int main(int argc, char **argv)
 
     parse_args(&options, argc, argv);
 
-    client = MqttClientNew(options.client_id, options.clean);
+    client = MqttClientNew(options.client_id);
 
     MqttClientSetOnConnect(client, onConnect);
     MqttClientSetOnSubscribe(client, onSubscribe);
     MqttClientSetOnMessage(client, onMessage);
     MqttClientSetUserData(client, &options);
 
-    MqttClientConnect(client, "test.mosquitto.org", 1883, 60);
+    MqttClientConnect(client, "test.mosquitto.org", 1883, 60, options.clean);
 
     MqttClientRun(client);