Add fatal log to onConnectionLost handler to respect terminate OnConnectError (#184)

gbird3 · Greg Bird · web-flow · commit ce46f7649854 · 2021-01-28T21:39:24.000Z
Co-authored-by: Greg Bird &lt;greg.bird@joltup.com&gt;
diff --git a/internal/integration/mqtt/backend.go b/internal/integration/mqtt/backend.go
@@ -382,6 +382,9 @@ func (b *Backend) subscribeLoop() {
 }
 
 func (b *Backend) onConnectionLost(c paho.Client, err error) {
+	if b.terminateOnConnectError {
+		log.Fatal(err)
+	}
 	mqttDisconnectCounter().Inc()
 	log.WithError(err).Error("mqtt: connection error")
 }

Original file line number	Diff line number	Diff line change
`@@ -382,6 +382,9 @@ func (b *Backend) subscribeLoop() {`
`382`	`382`	`}`
`383`	`383`
`384`	`384`	`func (b *Backend) onConnectionLost(c paho.Client, err error) {`
	`385`	`+ if b.terminateOnConnectError {`
	`386`	`+ log.Fatal(err)`
	`387`	`+ }`
`385`	`388`	`mqttDisconnectCounter().Inc()`
`386`	`389`	`log.WithError(err).Error("mqtt: connection error")`
`387`	`390`	`}`