Verschiebe callback-handling nach 'mqtt_run'

1 files changed, 4 insertions, 2 deletions

diff --git a/src/subscribe.c b/src/subscribe.c
index e7d5883..b016283 100644
--- a/src/subscribe.c
+++ b/src/subscribe.c
@@ -65,14 +65,16 @@ main(void)
             PASSWORD,
             HOSTNAME,
             PORT,
-            callback,
             NULL);
 
         if ( !client ) {
                 return EXIT_FAILURE;
         }
 
-        mqtt_run(client, (const char *[]){ TOPIC, "testtopic", NULL }, &terminate);
+        mqtt_run(client,
+                 (const char *[]){ TOPIC, "testtopic", NULL },
+                 callback,
+                 &terminate);
 
         mqtt_shutdown(client);