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

增加错误判断

Browse Source
This commit is contained in:
ssp97 2024-08-22 22:09:23 +08:00
parent 5aeab97385
commit 400aeae5b8
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
mqtt/client.go
View File

@ -75,6 +75,9 @@ func MqttClientSubscribe(session *Session, topic string, qos byte) {
} }
func MqttClientUnsubscribe(session *Session, topic string) { func MqttClientUnsubscribe(session *Session, topic string) {
if session == nil {
return
}
client := *session.Client client := *session.Client
client.Unsubscribe(topic) client.Unsubscribe(topic)
} }