|
|
@@ -142,6 +142,8 @@ func (r *MQTTReporter) tick() time.Duration {
|
|
|
return FastInterval
|
|
|
}
|
|
|
|
|
|
+ baseapp.Logger.Infof("[%s] 尝试连接、登录服务器(%s)...", MODULE_NAME, CfgServers.MQTTSrv.Address)
|
|
|
+
|
|
|
if err := r.connect(); err != nil {
|
|
|
baseapp.Logger.Errorf("[%s] 无法连接上服务器: %v!!", MODULE_NAME, err)
|
|
|
} else if err := r.subLoginResp(); err != nil {
|