From 326c46cb276fd84e1207f707380cd9e37d8eb26e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Szak=C3=A1ts=20Alp=C3=A1r=20Zsolt?= Date: Tue, 19 Aug 2025 12:59:19 +0200 Subject: [PATCH] Subscribes to a broader telemetry topic 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. --- Source/ProofOfConcept/Services/MQTTClient.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Source/ProofOfConcept/Services/MQTTClient.cs b/Source/ProofOfConcept/Services/MQTTClient.cs index 400f79b..c9828ce 100644 --- a/Source/ProofOfConcept/Services/MQTTClient.cs +++ b/Source/ProofOfConcept/Services/MQTTClient.cs @@ -41,7 +41,7 @@ public class MQTTClient : IHostedService await this.client.ConnectAsync(options, cancellationToken); this.logger.LogTrace("Connected"); - await this.client.SubscribeAsync("telemetry", cancellationToken: cancellationToken); + await this.client.SubscribeAsync("telemetry/#", cancellationToken: cancellationToken); this.logger.LogTrace("Subscribed"); this.logger.LogInformation("Started");