diff --git a/backend/services/controller/internal/mqtt/mqtt.go b/backend/services/controller/internal/mqtt/mqtt.go index 2db7a2a..ca5cf6d 100644 --- a/backend/services/controller/internal/mqtt/mqtt.go +++ b/backend/services/controller/internal/mqtt/mqtt.go @@ -140,6 +140,12 @@ func (m *Mqtt) startClient(devices, controller, disconnect, apiMsg chan *paho.Pu clientConfig := paho.ClientConfig{ Conn: conn, Router: singleHandler, + OnServerDisconnect: func(disconnect *paho.Disconnect) { + log.Println("disconnected from mqtt server, reason code: ", disconnect.ReasonCode) + }, + OnClientError: func(err error) { + log.Println(err) + }, } return paho.NewClient(clientConfig)