From 57ebbc7c45d14f9c6ce51b5264886981c7d44a86 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Leandro=20Ant=C3=B4nio=20Farias=20Machado?= Date: Fri, 16 Jun 2023 00:12:54 -0300 Subject: [PATCH] chore(controller): show alert on broker disconnection --- backend/services/controller/internal/mqtt/mqtt.go | 6 ++++++ 1 file changed, 6 insertions(+) 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)