netutils/mqtt
1
0
Fork 0
mirror of https://github.com/go-mqtt/mqtt.git synced 2025-08-08 22:42:05 +03:00
Code Activity

Apply strict quit handling.

Browse Source
This commit is contained in:
Pascal S. de Kloe
2021-02-05 16:27:34 +01:00
parent 322b0dc3c2
commit 11095ddd8d
7 changed files with 80 additions and 73 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
cmd/mqttc/main.go
View File

@@ -145,7 +145,7 @@ func main() {
if err != nil {
log.Fatal(err)
}
err = client.Publish(message, *publishFlag)
err = client.Publish(nil, message, *publishFlag)
switch {
case err == nil:
if *verboseFlag {
@@ -167,9 +167,9 @@ func main() {
err := client.SubscribeLimitAtMostOnce(ctx.Done(), subscribeFlags...)
switch {
case err == nil, errors.Is(err, mqtt.ErrClosed), errors.Is(err, mqtt.ErrDown):
return // OK
case errors.Is(err, mqtt.ErrAbandon):
log.Fatal(name, ": subscribe timeout")
return
case errors.Is(err, mqtt.ErrCanceled), errors.Is(err, mqtt.ErrAbandoned):
log.Print(name, ": subscribe timeout")
fallthrough
default:
@@ -189,7 +189,7 @@ func main() {
break // OK
case errors.Is(err, mqtt.ErrClosed), errors.Is(err, mqtt.ErrDown):
return
case errors.Is(err, mqtt.ErrAbandon):
case errors.Is(err, mqtt.ErrCanceled), errors.Is(err, mqtt.ErrAbandoned):
log.Print(name, ": ping timeout")
fallthrough