ssp97/mqtt_relay
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

del printf on MqttClientSubscribe

Browse Source
This commit is contained in:
ssp97 2024-08-22 20:30:42 +08:00
parent f3310713fc
commit 9069d1293c
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
mqtt/client.go
View File

@ -51,7 +51,7 @@ func MqttClientDisconnect(session *Session) {
func MqttClientSubscribeMultiple(session *Session, filters map[string]byte) { func MqttClientSubscribeMultiple(session *Session, filters map[string]byte) {
client := *session.Client client := *session.Client
client.SubscribeMultiple(filters, func(client mqttClient.Client, msg mqttClient.Message) { 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() server := GetMqttServer()
err := server.Publish(msg.Topic(), msg.Payload(), msg.Retained(), msg.Qos()) err := server.Publish(msg.Topic(), msg.Payload(), msg.Retained(), msg.Qos())
if err != nil { if err != nil {
@ -63,7 +63,7 @@ func MqttClientSubscribeMultiple(session *Session, filters map[string]byte) {
func MqttClientSubscribe(session *Session, topic string, qos byte) { func MqttClientSubscribe(session *Session, topic string, qos byte) {
client := *session.Client client := *session.Client
client.Subscribe(topic, qos, func(client mqtt.Client, msg mqtt.Message) { 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() server := GetMqttServer()
err := server.Publish(msg.Topic(), msg.Payload(), msg.Retained(), msg.Qos()) err := server.Publish(msg.Topic(), msg.Payload(), msg.Retained(), msg.Qos())
if err != nil { if err != nil {