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");