mirror of
https://github.com/planetmint/planetmint-go.git
synced 2025-05-12 10:52:29 +00:00
using the defined function (#476)
Signed-off-by: Jürgen Eckel <juergen@riddleandcode.com>
This commit is contained in:
parent
b48432f541
commit
ae086b9b37
@ -296,9 +296,7 @@ func (mms *MqttMonitor) onConnectionLost(_ mqtt.Client, err error) {
|
|||||||
Log("connection lost: " + err.Error())
|
Log("connection lost: " + err.Error())
|
||||||
// Handle connection loss here (e.g., reconnect attempts, logging)
|
// Handle connection loss here (e.g., reconnect attempts, logging)
|
||||||
if !mms.IsTerminated() {
|
if !mms.IsTerminated() {
|
||||||
mms.lostConnectionMutex.Lock()
|
mms.setConnectionStatus(true)
|
||||||
mms.lostConnection = true
|
|
||||||
mms.lostConnectionMutex.Unlock()
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user