diff --git a/monitor/mqtt_monitor.go b/monitor/mqtt_monitor.go index 6079e80..94c4b53 100644 --- a/monitor/mqtt_monitor.go +++ b/monitor/mqtt_monitor.go @@ -51,7 +51,7 @@ func (mms *MqttMonitor) IsTerminated() (isTerminated bool) { func getClientID() string { conf := config.GetConfig() - return "-monitor" + conf.ValidatorAddress + return "monitor-" + conf.ValidatorAddress } func (mms *MqttMonitor) lazyLoadMonitorMQTTClient() util.MQTTClientI {