From c04024e9b4c675f1a55ab89b66ffdfce914480e3 Mon Sep 17 00:00:00 2001 From: Peace Date: Fri, 9 Aug 2024 14:44:06 +0900 Subject: [PATCH] log duplication fix --- MQTTSample/MqttMultiTopicClientApp/Program.cs | 2 ++ MQTTSample/PMqttClient/MqttMultiTopicClient.cs | 6 ------ 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/MQTTSample/MqttMultiTopicClientApp/Program.cs b/MQTTSample/MqttMultiTopicClientApp/Program.cs index f8e81cf..85647c1 100644 --- a/MQTTSample/MqttMultiTopicClientApp/Program.cs +++ b/MQTTSample/MqttMultiTopicClientApp/Program.cs @@ -17,6 +17,8 @@ namespace MqttMultiTopicClientApp await _mqttClient.AddTopicAsync("home/livingroom/temperature", MqttQoSLevel.AtLeastOnce); + await Task.Delay(1000); + await _mqttClient.ConnectAsync(SERVER_IP, PORT, $"cid_{Random.Shared.Next(1, 1000)}"); await _mqttClient.AddTopicAsync("home/bedroom/humidity", MqttQoSLevel.AtMostOnce); diff --git a/MQTTSample/PMqttClient/MqttMultiTopicClient.cs b/MQTTSample/PMqttClient/MqttMultiTopicClient.cs index da99d75..1acd744 100644 --- a/MQTTSample/PMqttClient/MqttMultiTopicClient.cs +++ b/MQTTSample/PMqttClient/MqttMultiTopicClient.cs @@ -53,8 +53,6 @@ namespace PMqttClient _topics.Add(topic, qos); if (_mqttClient.IsConnected) await SubscribeAsync(topic, qos); - - WriteLog($"topic '{topic}' is added."); } public async Task RemoveTopicAsync(string topic) @@ -107,11 +105,7 @@ namespace PMqttClient WriteLog("Connected to MQTT Broker."); foreach (var topic in _topics) - { await SubscribeAsync(topic.Key, topic.Value); - - WriteLog($"Subscribed to topic: {topic.Key} with QoS {topic.Value.ToString()}."); - } } private void WriteLog(string message)