suguo
/
jetlinks-community
mirror of https://gitee.com/jetlinks/jetlinks-community.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor: 优化

This commit is contained in:
zhouhao 2025-09-11 09:31:02 +08:00
parent 20f589999a
commit dcdba73994
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/gateway/device/session/MqttClientSession.java
View File

@ -133,8 +133,7 @@ public class MqttClientSession implements PersistentSession {
@Override
public boolean isAlive() {
return (clientTemp == null || clientTemp.isAlive()) &&
(keepAliveTimeout <= 0 || System.currentTimeMillis() - lastPingTime < keepAliveTimeout);
return keepAliveTimeout <= 0 || System.currentTimeMillis() - lastPingTime < keepAliveTimeout;
}
@Override

1
jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/message/DefaultDeviceDataManager.java
View File

@ -235,6 +235,7 @@ public class DefaultDeviceDataManager implements DeviceDataManager {
"/device/*/" + deviceId + "/message/property/read,write/reply")
.broker()
.local()
.priority(Integer.MIN_VALUE)
.build();
disposable = eventBus