apps/mqtt-benchmark
1
0
Fork 0
mirror of https://github.com/wwhai/mqtt-benchmark.git synced 2025-10-04 23:32:46 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fixed MQTT ClientID for compatibility with Mosquitto + Auth Plugin

Browse Source
This commit is contained in:
Craig Hesling
2018-06-12 18:38:21 -04:00
parent c71d74a0df
commit 248fb2ce21
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
client.go
View File

@@ -118,7 +118,7 @@ func (c *Client) pubMessages(in, out chan *Message, doneGen, donePub chan bool)
opts := mqtt.NewClientOptions(). opts := mqtt.NewClientOptions().
AddBroker(c.BrokerURL). AddBroker(c.BrokerURL).
SetClientID(fmt.Sprintf("mqtt-benchmark-%v-%v", time.Now(), c.ID)). SetClientID(fmt.Sprintf("mqtt-benchmark-%v-%v", time.Now().Format(time.RFC3339Nano), c.ID)).
SetCleanSession(true). SetCleanSession(true).
SetAutoReconnect(true). SetAutoReconnect(true).
SetOnConnectHandler(onConnected). SetOnConnectHandler(onConnected).