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) + } + }