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 2024-04-19 11:34:13 +08:00
parent a83ba95124
commit 9157c88024
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
jetlinks-components/gateway-component/src/main/java/org/jetlinks/community/gateway/DeviceGatewayHelper.java
View File

@ -34,13 +34,11 @@ import java.util.function.Supplier;
* @since 1.5
*/
@AllArgsConstructor
@Getter
public class DeviceGatewayHelper {
@Getter
private final DeviceRegistry registry;
@Getter
private final DeviceSessionManager sessionManager;
@Getter
private final DecodedClientMessageHandler messageHandler;
public static Consumer<DeviceSession> applySessionKeepaliveTimeout(DeviceMessage msg, Supplier<Duration> timeoutSupplier) {
@ -112,7 +110,7 @@ public class DeviceGatewayHelper {
return sessionManager
.remove(childrenId, removeSessionOnlyLocal(children))
.doOnNext(total -> {
if (total > 0) {
if (total > 0 && children instanceof DeviceOfflineMessage) {
children.addHeader(Headers.ignore, true);
}
})