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 {