From 9069d1293c9a4b992dd0a0f3c236d65c7281b19a Mon Sep 17 00:00:00 2001 From: ssp97 Date: Thu, 22 Aug 2024 20:30:42 +0800 Subject: [PATCH] del printf on MqttClientSubscribe --- mqtt/client.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/mqtt/client.go b/mqtt/client.go index cc27807..625752f 100644 --- a/mqtt/client.go +++ b/mqtt/client.go @@ -51,7 +51,7 @@ func MqttClientDisconnect(session *Session) { func MqttClientSubscribeMultiple(session *Session, filters map[string]byte) { client := *session.Client client.SubscribeMultiple(filters, func(client mqttClient.Client, msg mqttClient.Message) { - log.Printf("Received message on topic %s: %s\n", msg.Topic(), msg.Payload()) + //log.Printf("Received message on topic %s: %s\n", msg.Topic(), msg.Payload()) server := GetMqttServer() err := server.Publish(msg.Topic(), msg.Payload(), msg.Retained(), msg.Qos()) if err != nil { @@ -63,7 +63,7 @@ func MqttClientSubscribeMultiple(session *Session, filters map[string]byte) { func MqttClientSubscribe(session *Session, topic string, qos byte) { client := *session.Client client.Subscribe(topic, qos, func(client mqtt.Client, msg mqtt.Message) { - log.Printf("Received message on topic %s: %s\n", msg.Topic(), msg.Payload()) + //log.Printf("Received message on topic %s: %s\n", msg.Topic(), msg.Payload()) server := GetMqttServer() err := server.Publish(msg.Topic(), msg.Payload(), msg.Retained(), msg.Qos()) if err != nil {