fix: Wait for MQTT subscriptions to take effect before returning (#516)

MQTTAsync_subscribe() is async. There are some places e.g. startConfigured() where we expect the subscription to be in effect right after this call. So wait for completion before returning. Fixes: #516 Signed-off-by: Corey Mutter <[email protected]>
edgexfoundry · Oct 23, 2024 · d2bfa6c · d2bfa6c
1 parent de2f7dd
commit d2bfa6c
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/c/bus-mqtt.c b/src/c/bus-mqtt.c
@@ -73,6 +73,10 @@ static void edgex_bus_mqtt_subscribe (void *ctx, const char *topic)
   {
     iot_log_error (cinfo->lc, "mqtt: unable to subscribe to %s, error code %d", topic, rc);
   }
+  else
+  {
+    MQTTAsync_waitForCompletion(cinfo->client, opts.token, 1000);
+  }
 }
 
 static void edgex_bus_mqtt_post (void *ctx, const char *topic, const iot_data_t *envelope)