Subscribes to a broader telemetry topic
All checks were successful
Build, Push and Run Container / build (push) Successful in 30s
All checks were successful
Build, Push and Run Container / build (push) Successful in 30s
Updates the MQTT client to subscribe to all subtopics under "telemetry" using the wildcard "#". This allows the client to receive messages from various telemetry sources, improving data ingestion.
This commit is contained in:
@@ -41,7 +41,7 @@ public class MQTTClient : IHostedService
|
|||||||
await this.client.ConnectAsync(options, cancellationToken);
|
await this.client.ConnectAsync(options, cancellationToken);
|
||||||
this.logger.LogTrace("Connected");
|
this.logger.LogTrace("Connected");
|
||||||
|
|
||||||
await this.client.SubscribeAsync("telemetry", cancellationToken: cancellationToken);
|
await this.client.SubscribeAsync("telemetry/#", cancellationToken: cancellationToken);
|
||||||
this.logger.LogTrace("Subscribed");
|
this.logger.LogTrace("Subscribed");
|
||||||
|
|
||||||
this.logger.LogInformation("Started");
|
this.logger.LogInformation("Started");
|
||||||
|
|||||||
Reference in New Issue
Block a user