summaryrefslogtreecommitdiff
path: root/src/mqtt.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/mqtt.c')
-rw-r--r--src/mqtt.c6
1 files changed, 2 insertions, 4 deletions
diff --git a/src/mqtt.c b/src/mqtt.c
index 5a8bfc0..be4b9d2 100644
--- a/src/mqtt.c
+++ b/src/mqtt.c
@@ -49,10 +49,8 @@ mqtt_handle_messages(struct mosquitto *client,
49 mosquitto_message_callback_set(client, callback); 49 mosquitto_message_callback_set(client, callback);
50 } 50 }
51 51
52 int *mid = NULL;
53
54 for ( size_t idx = 0; topics[idx] != NULL; ++idx ) { 52 for ( size_t idx = 0; topics[idx] != NULL; ++idx ) {
55 mosquitto_subscribe(client, mid, topics[idx], 0); 53 mosquitto_subscribe(client, NULL, topics[idx], 0);
56 } 54 }
57 55
58 while ( !*quit ) { 56 while ( !*quit ) {
@@ -67,7 +65,7 @@ mqtt_handle_messages(struct mosquitto *client,
67 } 65 }
68 66
69 for ( size_t idx = 0; topics[idx] != NULL; ++idx ) { 67 for ( size_t idx = 0; topics[idx] != NULL; ++idx ) {
70 mosquitto_unsubscribe(client, mid, topics[idx]); 68 mosquitto_unsubscribe(client, NULL, topics[idx]);
71 } 69 }
72} 70}
73 71