OrgGo/mqttcli
1
0
Fork 0
mirror of https://github.com/shirou/mqttcli.git synced 2025-04-26 13:49:17 +08:00
Code Issues Projects Releases Wiki Activity

if host and port specified, not read from file.

Browse Source
This commit is contained in:
Shirou WAKAYAMA 2014-10-17 14:41:29 +09:00
parent a1c7c40724
commit e6d0151ae9
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
mqtt.go
View File

@ -76,7 +76,12 @@ func getRandomClientId() string {
func NewOption(c *cli.Context) *MQTT.ClientOptions {
opts := MQTT.NewClientOptions()
getSettingsFromFile(c.String("conf"), opts)
host := c.String("host")
port := c.Int("p")
if host == "" && port == 0 {
getSettingsFromFile(c.String("conf"), opts)
}
clientId := c.String("i")
if clientId == "" {
@ -104,8 +109,6 @@ func NewOption(c *cli.Context) *MQTT.ClientOptions {
opts.SetPassword(password)
}
host := c.String("host")
port := c.Int("p")
if host != "" {
brokerUri := fmt.Sprintf("%s://%s:%d", scheme, host, port)
log.Infof("Broker URI: %s", brokerUri)