1 files changed, 4 insertions, 4 deletions

diff --git a/src/subscribe.c b/src/subscribe.c
index b016283..abe862b 100644
--- a/src/subscribe.c
+++ b/src/subscribe.c
@@ -71,10 +71,10 @@ main(void)
                 return EXIT_FAILURE;
         }
 
-        mqtt_run(client,
-                 (const char *[]){ TOPIC, "testtopic", NULL },
-                 callback,
-                 &terminate);
+        mqtt_handle_messages(client,
+                             (const char *[]){ TOPIC, "testtopic", NULL },
+                             callback,
+                             &terminate);
 
         mqtt_shutdown(client);