From 03d36a9ac781d2b1ed54da3eeeb3925930bdca23 Mon Sep 17 00:00:00 2001
From: lin <648540858@qq.com>
Date: Thu, 18 Jun 2026 10:32:43 +0800
Subject: [PATCH] =?UTF-8?q?message=E5=9B=9E=E8=B0=83=E4=BA=8B=E4=BB=B6?=
 =?UTF-8?q?=E6=94=AF=E6=8C=81=E5=8D=95sn=E5=A4=9A=E5=9B=9E=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../genersoft/iot/vmp/gb28181/event/sip/MessageEvent.java    | 2 ++
 .../event/request/impl/message/MessageHandlerAbstract.java   | 4 +++-
 .../service/redisMsg/control/RedisRpcDeviceController.java   | 5 +----
 3 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/event/sip/MessageEvent.java b/src/main/java/com/genersoft/iot/vmp/gb28181/event/sip/MessageEvent.java
index e55fce368..fd9f22d67 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/event/sip/MessageEvent.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/event/sip/MessageEvent.java
@@ -22,6 +22,8 @@ public class MessageEvent<T> implements Delayed {
 
     private String result;
 
+    private boolean keepAlive = false;
+
     private T t;
 
     private ErrorCallback<T> callback;
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/MessageHandlerAbstract.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/MessageHandlerAbstract.java
index b1dc99a66..66027d6a1 100755
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/MessageHandlerAbstract.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/MessageHandlerAbstract.java
@@ -87,7 +87,9 @@ public abstract class MessageHandlerAbstract extends SIPRequestProcessorParent i
             }else {
                 subscribe.getCallback().run(ErrorCode.ERROR100.getCode(), ErrorCode.ERROR100.getMsg(), result);
             }
-            messageSubscribe.removeSubscribe(cmd + sn);
+            if (!subscribe.isKeepAlive()) {
+                messageSubscribe.removeSubscribe(cmd + sn);
+            }
         }
     }
 }
diff --git a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/control/RedisRpcDeviceController.java b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/control/RedisRpcDeviceController.java
index 29f95d23c..26f26ee97 100644
--- a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/control/RedisRpcDeviceController.java
+++ b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/control/RedisRpcDeviceController.java
@@ -7,10 +7,7 @@ import com.genersoft.iot.vmp.conf.redis.RedisRpcConfig;
 import com.genersoft.iot.vmp.conf.redis.bean.RedisRpcMessage;
 import com.genersoft.iot.vmp.conf.redis.bean.RedisRpcRequest;
 import com.genersoft.iot.vmp.conf.redis.bean.RedisRpcResponse;
-import com.genersoft.iot.vmp.gb28181.bean.BasicParam;
-import com.genersoft.iot.vmp.gb28181.bean.Device;
-import com.genersoft.iot.vmp.gb28181.bean.DeviceConfigAware;
-import com.genersoft.iot.vmp.gb28181.bean.SyncStatus;
+import com.genersoft.iot.vmp.gb28181.bean.*;
 import com.genersoft.iot.vmp.gb28181.service.IDeviceService;
 import com.genersoft.iot.vmp.service.redisMsg.dto.RedisRpcController;
 import com.genersoft.iot.vmp.service.redisMsg.dto.RedisRpcMapping;