Set auto-reconnect to true in order to buffer messages.

brocaar · brocaar · commit c5536c663f9d · 2019-07-19T09:51:16.000+02:00
When auto-reconnect is set to false, the paho library will not persist
messages when the client is offline.
diff --git a/internal/integration/mqtt/backend.go b/internal/integration/mqtt/backend.go
@@ -118,7 +118,7 @@ func NewBackend(conf config.Config) (*Backend, error) {
 	}
 
 	b.clientOpts.SetProtocolVersion(4)
-	b.clientOpts.SetAutoReconnect(false)
+	b.clientOpts.SetAutoReconnect(true) // this is required for buffering messages in case offline!
 	b.clientOpts.SetOnConnectHandler(b.onConnected)
 	b.clientOpts.SetConnectionLostHandler(b.onConnectionLost)
 
@@ -288,7 +288,6 @@ func (b *Backend) onConnected(c paho.Client) {
 func (b *Backend) onConnectionLost(c paho.Client, err error) {
 	mqttDisconnectCounter().Inc()
 	log.WithError(err).Error("mqtt: connection error")
-	b.connectLoop()
 }
 
 func (b *Backend) handleDownlinkFrame(c paho.Client, msg paho.Message) {

Original file line number	Diff line number	Diff line change
`@@ -118,7 +118,7 @@ func NewBackend(conf config.Config) (*Backend, error) {`
`118`	`118`	`}`
`119`	`119`
`120`	`120`	`b.clientOpts.SetProtocolVersion(4)`
`121`		`- b.clientOpts.SetAutoReconnect(false)`
	`121`	`+ b.clientOpts.SetAutoReconnect(true) // this is required for buffering messages in case offline!`
`122`	`122`	`b.clientOpts.SetOnConnectHandler(b.onConnected)`
`123`	`123`	`b.clientOpts.SetConnectionLostHandler(b.onConnectionLost)`
`124`	`124`
`@@ -288,7 +288,6 @@ func (b *Backend) onConnected(c paho.Client) {`
`288`	`288`	`func (b *Backend) onConnectionLost(c paho.Client, err error) {`
`289`	`289`	`mqttDisconnectCounter().Inc()`
`290`	`290`	`log.WithError(err).Error("mqtt: connection error")`
`291`		`- b.connectLoop()`
`292`	`291`	`}`
`293`	`292`
`294`	`293`	`func (b *Backend) handleDownlinkFrame(c paho.Client, msg paho.Message) {`