瀏覽代碼

触发子设备session注册事件

zhou-hao 4 年之前
父節點
當前提交
c728da0e4f

+ 4 - 1
jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/configuration/DefaultDeviceSessionManager.java

@@ -227,7 +227,10 @@ public class DefaultDeviceSessionManager implements DeviceSessionManager {
                     .online(session.getServerId().orElse(serverId), session.getId(), session.getClientAddress().map(String::valueOf).orElse(null))
                     .then(deviceOperator.setConfig(DeviceConfigKey.parentGatewayId, deviceId))
                     .thenReturn(new ChildrenDeviceSession(childrenDeviceId, session, deviceOperator)))
-                .doOnNext(s -> children.computeIfAbsent(deviceId, __ -> new ConcurrentHashMap<>()).put(childrenDeviceId, s));
+                .doOnNext(s ->{
+                    registerListener.next(s);
+                    children.computeIfAbsent(deviceId, __ -> new ConcurrentHashMap<>()).put(childrenDeviceId, s);
+                });
         });
 
     }