From 37dd8ed965a3d87e00be05dda51027bf604e8691 Mon Sep 17 00:00:00 2001 From: Shirou WAKAYAMA Date: Mon, 25 Jul 2016 22:34:06 +0900 Subject: [PATCH] add error handling. --- main.go | 5 ++++- mqtt.go | 5 ++++- publish.go | 6 +++++- 3 files changed, 13 insertions(+), 3 deletions(-) diff --git a/main.go b/main.go index 27614e8..6374bc4 100644 --- a/main.go +++ b/main.go @@ -257,7 +257,10 @@ func main() { Action: pubsub, }, } - app.Run(os.Args) + err := app.Run(os.Args) + if err != nil { + log.Error(err) + } } func setDebugLevel(c *cli.Context) { diff --git a/mqtt.go b/mqtt.go index 37f7437..d4458d6 100644 --- a/mqtt.go +++ b/mqtt.go @@ -107,7 +107,10 @@ func NewOption(c *cli.Context) (*MQTT.ClientOptions, error) { port := c.Int("p") if host == "" { - getSettingsFromFile(c.String("conf"), opts) + err := getSettingsFromFile(c.String("conf"), opts) + if err != nil { + return nil, err + } } clientId := c.String("i") diff --git a/publish.go b/publish.go index d4b5250..e4cc615 100644 --- a/publish.go +++ b/publish.go @@ -51,5 +51,9 @@ func publish(c *cli.Context) { } log.Info("Published") - client.Disconnect() + err = client.Disconnect() + if err != nil { + log.Errorf("disconnect error: %s", err) + } + }