fix(设备消息): 修复设备消息订阅报错 (#431)

PropertyMessage类型没有默认的解码实现，已改为订阅ThingMessage
jetlinks · Oct 26, 2023 · 807f162 · 807f162
1 parent 7746a59
commit 807f162
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/...mponent/src/main/java/org/jetlinks/community/things/data/AutoUpdateThingsDataManager.java b/...mponent/src/main/java/org/jetlinks/community/things/data/AutoUpdateThingsDataManager.java
@@ -8,6 +8,7 @@
 import org.jetlinks.community.things.ThingConstants;
 import org.jetlinks.core.event.EventBus;
 import org.jetlinks.core.event.Subscription;
+import org.jetlinks.core.message.ThingMessage;
 import org.jetlinks.core.message.property.PropertyMessage;
 import org.jetlinks.core.things.ThingId;
 import org.jetlinks.core.things.ThingProperty;
@@ -173,14 +174,17 @@ public Updater(String thingType, String thingId) {
                                 .broker()
                                 .priority(Integer.MIN_VALUE)
                                 .build(),
-                    PropertyMessage.class
+                    ThingMessage.class
                 )
                 .doOnNext(this::doUpdate)
                 .subscribe();
         }
 
-        private void doUpdate(PropertyMessage message) {
-
+        private void doUpdate(ThingMessage thingMessage) {
+            if (!(thingMessage instanceof PropertyMessage)) {
+                return;
+            }
+            PropertyMessage message = (PropertyMessage) thingMessage;
             try {
                 Map<String, Object> properties = message.getProperties();
                 if (properties == null) {