diff options
| author | Thomas Schmucker <ts@its1.de> | 2026-07-11 13:59:01 +0200 |
|---|---|---|
| committer | Thomas Schmucker <ts@its1.de> | 2026-07-11 13:59:01 +0200 |
| commit | 7735ded57fbb5834efc2f6185fb668ec70923e7f (patch) | |
| tree | 84cda872968412e0fbb0de5c90977dd489bfec1a /src/mqtt.c | |
| parent | e2e32a1410331f2c478d61b3ecd0a0baf4aec511 (diff) | |
| download | use-mosquitto-7735ded57fbb5834efc2f6185fb668ec70923e7f.tar.gz use-mosquitto-7735ded57fbb5834efc2f6185fb668ec70923e7f.tar.bz2 use-mosquitto-7735ded57fbb5834efc2f6185fb668ec70923e7f.zip | |
Diffstat (limited to 'src/mqtt.c')
| -rw-r--r-- | src/mqtt.c | 6 |
1 files changed, 2 insertions, 4 deletions
| @@ -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 | ||
