refactor: 优化

Author: zhou-hao

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

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

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

@@ -235,6 +235,7 @@ public DevicePropertyRef(String deviceId, EventBus eventBus, DeviceDataService d
                         "/device/*/" + deviceId + "/message/property/read,write/reply")
                 .broker()
                 .local()
+                .priority(Integer.MIN_VALUE)
                 .build();
 
             disposable = eventBus