1、优化MQTT初始连接
This commit is contained in:
parent
c7b1438d02
commit
d6d3213f72
@ -42,7 +42,7 @@ public class GXJKForwarder extends Forwarder {
|
|||||||
mqttClient.connect();
|
mqttClient.connect();
|
||||||
}
|
}
|
||||||
catch (Exception e){
|
catch (Exception e){
|
||||||
|
logger.error("gxjk mqtt connect failed: {}",e.toString());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -58,7 +58,7 @@ public class GXJKForwarder extends Forwarder {
|
|||||||
mqttClient.connect();
|
mqttClient.connect();
|
||||||
}
|
}
|
||||||
catch (Exception e){
|
catch (Exception e){
|
||||||
|
logger.error("gxjk mqtt connect failed: {}",e.toString());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user