dsutanto/backone-manage-go
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Print out ClientID

Browse Source
This commit is contained in:
Dedy Sutanto
2026-02-02 14:13:17 +07:00
parent 7f298edf60
commit c2ce10fe15
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
mqtt_presence_redis_go/mqtt_presence_redis_go.go
+2 -1
View File
@@ -54,6 +54,7 @@ func main() {
opts.SetUsername(mqttUser) opts.SetUsername(mqttUser)
opts.SetPassword(mqttPass) opts.SetPassword(mqttPass)
opts.SetClientID(fmt.Sprintf("mqtt_presence_redis_go_%s", randomString())) opts.SetClientID(fmt.Sprintf("mqtt_presence_redis_go_%s", randomString()))
// clientID variable removed; use opts.ClientID directly
// Handlers // Handlers
opts.SetDefaultPublishHandler(func(client mqtt.Client, msg mqtt.Message) { opts.SetDefaultPublishHandler(func(client mqtt.Client, msg mqtt.Message) {
@@ -64,7 +65,7 @@ func main() {
if token := c.Subscribe(mqttTopicPresence, 0, nil); token.Wait() && token.Error() != nil { if token := c.Subscribe(mqttTopicPresence, 0, nil); token.Wait() && token.Error() != nil {
log.Fatalf("Failed to subscribe: %v", token.Error()) log.Fatalf("Failed to subscribe: %v", token.Error())
} }
log.Printf("Connected to MQTT broker %s:%s, subscribed to %s", mqttHost, mqttPort, mqttTopicPresence) log.Printf("Connected to MQTT broker %s:%s, subscribed to %s, client ID: %s", mqttHost, mqttPort, mqttTopicPresence, opts.ClientID)
} }
// Create and start client // Create and start client