Mirroristas/planetmint-go
2
0
Fork 0
mirror of https://github.com/planetmint/planetmint-go.git synced 2025-11-26 15:35:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

* set keepalive ping

Browse Source 
* made mutex more granular

Signed-off-by: Jürgen Eckel <juergen@riddleandcode.com>
This commit is contained in:
Jürgen Eckel 2024-05-14 23:17:12 +02:00
parent ccf491d658
commit c3bbf76dde
No known key found for this signature in database
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
monitor/mqtt_monitor.go
View File

@ -56,7 +56,7 @@ func LazyLoadMonitorMQTTClient() {
uri = "ssl://" + hostPort
}
opts := mqtt.NewClientOptions().AddBroker(uri)
opts := mqtt.NewClientOptions().AddBroker(uri).SetKeepAlive(60)
opts.SetClientID(conf.ValidatorAddress + "-monitor")
opts.SetUsername(conf.MqttUser)
opts.SetPassword(conf.MqttPassword)
@ -202,10 +202,12 @@ func (mms *MqttMonitor) MonitorActiveParticipants() {
func (mms *MqttMonitor) Log(msg string) {
mms.contextMutex.Lock()
if mms.sdkContext != nil {
util.GetAppLogger().Info(*mms.sdkContext, msg)
}
localContext := mms.sdkContext
mms.contextMutex.Unlock()
if localContext != nil {
util.GetAppLogger().Info(*localContext, msg)
}
}
func (mms *MqttMonitor) SetContext(ctx sdk.Context) {