lmoskala/mqtt2exec
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Retain availability

Browse source
This commit is contained in:
Łukasz Moskała 2024-12-22 20:35:07 +01:00
parent 0b1065e993
commit 74d2e3cb7c
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
main.go
View file

@ -33,7 +33,7 @@ func main() {
opts.OnConnect = connectHandler opts.OnConnect = connectHandler
opts.SetKeepAlive(20 * time.Second) opts.SetKeepAlive(20 * time.Second)
opts.SetAutoReconnect(true) opts.SetAutoReconnect(true)
opts.SetWill("mqtt2exec/"+os.Args[2]+"/state", "offline", 1, false) opts.SetWill("mqtt2exec/"+os.Args[2]+"/state", "offline", 1, true)
client := mqtt.NewClient(opts) client := mqtt.NewClient(opts)
sleep := 1 * time.Second sleep := 1 * time.Second
for { for {
@ -72,5 +72,5 @@ func connectHandler(c mqtt.Client) {
if token.Error() != nil { if token.Error() != nil {
log.Printf("mqtt2exec: Error subscribing to topic: %s", token.Error()) log.Printf("mqtt2exec: Error subscribing to topic: %s", token.Error())
} }
c.Publish("mqtt2exec/"+os.Args[2]+"/state", 1, false, "online") c.Publish("mqtt2exec/"+os.Args[2]+"/state", 1, true, "online")
} }