vs_utils/ConnectorDataMqtt
1
0
Fork 0
Code Issues Pull Requests Releases 5 Wiki Activity

improve logging

Browse Source
This commit is contained in:
BlubbFish 2026-08-04 12:11:13 +02:00
parent e5eb4c8740
commit 5357b57489
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ConnectorDataMqtt/Mqtt.cs
View File

@ -29,7 +29,7 @@ namespace BlubbFish.Utils.IoT.Connector.Data {
if (this.settings.ContainsKey("user")) { if (this.settings.ContainsKey("user")) {
ret += this.settings["user"]; ret += this.settings["user"];
if (this.settings.ContainsKey("pass")) { if (this.settings.ContainsKey("pass")) {
ret += ":" + this.settings["pass"]; ret += ":[xxx]";
} }
ret += "@"; ret += "@";
} }
@ -76,7 +76,7 @@ namespace BlubbFish.Utils.IoT.Connector.Data {
} }
private void Disconnect(Boolean complete) { private void Disconnect(Boolean complete) {
Console.WriteLine("BlubbFish.Utils.IoT.Connector.Data.Disconnect(" + this.ToString() + ")"); Console.WriteLine("BlubbFish.Utils.IoT.Connector.Data.Mqtt.Disconnect(" + this.ToString() + ")");
this.client.MqttMsgPublishReceived -= this.Client_MqttMsgPublishReceived; this.client.MqttMsgPublishReceived -= this.Client_MqttMsgPublishReceived;
this.Unsubscripe(); this.Unsubscripe();
if(complete) { if(complete) {
@ -85,7 +85,7 @@ namespace BlubbFish.Utils.IoT.Connector.Data {
} }
private void Connect() { private void Connect() {
Console.WriteLine("BlubbFish.Utils.IoT.Connector.Data.Connect(" + this.ToString() + ")"); Console.WriteLine("BlubbFish.Utils.IoT.Connector.Data.Mqtt.Connect(" + this.ToString() + ")");
this.client.MqttMsgPublishReceived += this.Client_MqttMsgPublishReceived; this.client.MqttMsgPublishReceived += this.Client_MqttMsgPublishReceived;
_ = this.settings.ContainsKey("user") && this.settings.ContainsKey("pass") _ = this.settings.ContainsKey("user") && this.settings.ContainsKey("pass")
? this.client.Connect(Guid.NewGuid().ToString(), this.settings["user"], this.settings["pass"]) ? this.client.Connect(Guid.NewGuid().ToString(), this.settings["user"], this.settings["pass"])