From 38681c39c150783503109929a106f43173393dbc Mon Sep 17 00:00:00 2001 From: lzh Date: Thu, 23 Apr 2026 15:05:00 +0800 Subject: [PATCH] =?UTF-8?q?refactor(video):=20ISIPProcessorObserver=20?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E8=A1=A5=E9=BD=90=E6=B3=A8=E5=86=8C=E6=96=B9?= =?UTF-8?q?=E6=B3=95=EF=BC=8Cprocessor=20=E6=94=B9=E4=BE=9D=E8=B5=96?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 原先 addRequestProcessor / addResponseProcessor 只在实现类 SIPProcessorObserver 上，13 个处理器在 afterPropertiesSet 里 @Autowired 实现类才能自注册，耦合到具体实现。 - 把两个 register 方法提到 ISIPProcessorObserver 接口上， 13 个 processor 的注入类型改为 ISIPProcessorObserver， 处理器侧不再感知具体实现，方便后续测试 mock / 多实现。 - 本次只改注入类型与接口签名，消息分发行为不变。 --- .../video/gb28181/transmit/ISIPProcessorObserver.java | 7 +++++++ .../transmit/event/request/impl/AckRequestProcessor.java | 4 ++-- .../transmit/event/request/impl/ByeRequestProcessor.java | 4 ++-- .../event/request/impl/CancelRequestProcessor.java | 4 ++-- .../event/request/impl/InviteRequestProcessor.java | 4 ++-- .../event/request/impl/NotifyRequestProcessor.java | 4 ++-- .../event/request/impl/RegisterRequestProcessor.java | 4 ++-- .../event/request/impl/SubscribeRequestProcessor.java | 4 ++-- .../event/request/impl/info/InfoRequestProcessor.java | 4 ++-- .../request/impl/message/MessageRequestProcessor.java | 4 ++-- .../transmit/event/response/impl/ByeResponseProcessor.java | 4 ++-- .../event/response/impl/CancelResponseProcessor.java | 4 ++-- .../event/response/impl/InviteResponseProcessor.java | 4 ++-- .../event/response/impl/RegisterResponseProcessor.java | 4 ++-- 14 files changed, 33 insertions(+), 26 deletions(-) diff --git a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/ISIPProcessorObserver.java b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/ISIPProcessorObserver.java index 0a949179..627712b0 100644 --- a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/ISIPProcessorObserver.java +++ b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/ISIPProcessorObserver.java @@ -1,6 +1,13 @@ package com.viewsh.module.video.gb28181.transmit; +import com.viewsh.module.video.gb28181.transmit.event.request.ISIPRequestProcessor; +import com.viewsh.module.video.gb28181.transmit.event.response.ISIPResponseProcessor; + import javax.sip.SipListener; public interface ISIPProcessorObserver extends SipListener { + + void addRequestProcessor(String method, ISIPRequestProcessor processor); + + void addResponseProcessor(String method, ISIPResponseProcessor processor); } diff --git a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/AckRequestProcessor.java b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/AckRequestProcessor.java index 54e9311d..fb7924e0 100644 --- a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/AckRequestProcessor.java +++ b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/AckRequestProcessor.java @@ -11,7 +11,7 @@ import com.viewsh.module.video.gb28181.service.IDeviceChannelService; import com.viewsh.module.video.gb28181.service.IDeviceService; import com.viewsh.module.video.gb28181.service.IPlatformService; import com.viewsh.module.video.gb28181.service.IPlayService; -import com.viewsh.module.video.gb28181.transmit.SIPProcessorObserver; +import com.viewsh.module.video.gb28181.transmit.ISIPProcessorObserver; import com.viewsh.module.video.gb28181.transmit.event.request.ISIPRequestProcessor; import com.viewsh.module.video.gb28181.transmit.event.request.SIPRequestProcessorParent; import com.viewsh.module.video.media.bean.MediaServer; @@ -43,7 +43,7 @@ public class AckRequestProcessor extends SIPRequestProcessorParent implements In private final String method = "ACK"; @Autowired - private SIPProcessorObserver sipProcessorObserver; + private ISIPProcessorObserver sipProcessorObserver; @Override public void afterPropertiesSet() throws Exception { diff --git a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/ByeRequestProcessor.java b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/ByeRequestProcessor.java index 07f50e33..e76437a1 100644 --- a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/ByeRequestProcessor.java +++ b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/ByeRequestProcessor.java @@ -8,7 +8,7 @@ import com.viewsh.module.video.gb28181.bean.*; import com.viewsh.module.video.gb28181.service.*; import com.viewsh.module.video.gb28181.session.AudioBroadcastManager; import com.viewsh.module.video.gb28181.session.SipInviteSessionManager; -import com.viewsh.module.video.gb28181.transmit.SIPProcessorObserver; +import com.viewsh.module.video.gb28181.transmit.ISIPProcessorObserver; import com.viewsh.module.video.gb28181.transmit.cmd.ISIPCommander; import com.viewsh.module.video.gb28181.transmit.event.request.ISIPRequestProcessor; import com.viewsh.module.video.gb28181.transmit.event.request.SIPRequestProcessorParent; @@ -71,7 +71,7 @@ public class ByeRequestProcessor extends SIPRequestProcessorParent implements In private IMediaServerService mediaServerService; @Autowired - private SIPProcessorObserver sipProcessorObserver; + private ISIPProcessorObserver sipProcessorObserver; @Autowired private SipInviteSessionManager sessionManager; diff --git a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/CancelRequestProcessor.java b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/CancelRequestProcessor.java index 2a6b945a..86797418 100644 --- a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/CancelRequestProcessor.java +++ b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/CancelRequestProcessor.java @@ -1,6 +1,6 @@ package com.viewsh.module.video.gb28181.transmit.event.request.impl; -import com.viewsh.module.video.gb28181.transmit.SIPProcessorObserver; +import com.viewsh.module.video.gb28181.transmit.ISIPProcessorObserver; import com.viewsh.module.video.gb28181.transmit.event.request.ISIPRequestProcessor; import com.viewsh.module.video.gb28181.transmit.event.request.SIPRequestProcessorParent; import org.springframework.beans.factory.InitializingBean; @@ -18,7 +18,7 @@ public class CancelRequestProcessor extends SIPRequestProcessorParent implements private final String method = "CANCEL"; @Autowired - private SIPProcessorObserver sipProcessorObserver; + private ISIPProcessorObserver sipProcessorObserver; @Override public void afterPropertiesSet() throws Exception { diff --git a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/InviteRequestProcessor.java b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/InviteRequestProcessor.java index 7acb50c6..f4576432 100644 --- a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/InviteRequestProcessor.java +++ b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/InviteRequestProcessor.java @@ -12,7 +12,7 @@ import com.viewsh.module.video.gb28181.service.*; import com.viewsh.module.video.gb28181.session.AudioBroadcastManager; import com.viewsh.module.video.gb28181.session.SSRCFactory; import com.viewsh.module.video.gb28181.session.SipInviteSessionManager; -import com.viewsh.module.video.gb28181.transmit.SIPProcessorObserver; +import com.viewsh.module.video.gb28181.transmit.ISIPProcessorObserver; import com.viewsh.module.video.gb28181.transmit.cmd.ISIPCommanderForPlatform; import com.viewsh.module.video.gb28181.transmit.event.request.ISIPRequestProcessor; import com.viewsh.module.video.gb28181.transmit.event.request.SIPRequestProcessorParent; @@ -91,7 +91,7 @@ public class InviteRequestProcessor extends SIPRequestProcessorParent implements private AudioBroadcastManager audioBroadcastManager; @Autowired - private SIPProcessorObserver sipProcessorObserver; + private ISIPProcessorObserver sipProcessorObserver; @Autowired private SipConfig config; diff --git a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java index b1c3e6b5..6faac40d 100644 --- a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java +++ b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java @@ -3,7 +3,7 @@ package com.viewsh.module.video.gb28181.transmit.event.request.impl; import com.viewsh.module.video.framework.sip.SipConfig; import com.viewsh.module.video.gb28181.bean.*; import com.viewsh.module.video.gb28181.event.EventPublisher; -import com.viewsh.module.video.gb28181.transmit.SIPProcessorObserver; +import com.viewsh.module.video.gb28181.transmit.ISIPProcessorObserver; import com.viewsh.module.video.gb28181.transmit.event.request.ISIPRequestProcessor; import com.viewsh.module.video.gb28181.transmit.event.request.SIPRequestProcessorParent; import com.viewsh.module.video.gb28181.utils.NumericUtil; @@ -46,7 +46,7 @@ public class NotifyRequestProcessor extends SIPRequestProcessorParent implements private final String method = "NOTIFY"; @Autowired - private SIPProcessorObserver sipProcessorObserver; + private ISIPProcessorObserver sipProcessorObserver; @Autowired private IDeviceChannelService deviceChannelService; diff --git a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/RegisterRequestProcessor.java b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/RegisterRequestProcessor.java index 9414a2bc..4d0ab426 100644 --- a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/RegisterRequestProcessor.java +++ b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/RegisterRequestProcessor.java @@ -9,7 +9,7 @@ import com.viewsh.module.video.gb28181.bean.GbSipDate; import com.viewsh.module.video.common.RemoteAddressInfo; import com.viewsh.module.video.gb28181.bean.SipTransactionInfo; import com.viewsh.module.video.gb28181.service.IDeviceService; -import com.viewsh.module.video.gb28181.transmit.SIPProcessorObserver; +import com.viewsh.module.video.gb28181.transmit.ISIPProcessorObserver; import com.viewsh.module.video.gb28181.transmit.SIPSender; import com.viewsh.module.video.gb28181.transmit.event.request.ISIPRequestProcessor; import com.viewsh.module.video.gb28181.transmit.event.request.SIPRequestProcessorParent; @@ -53,7 +53,7 @@ public class RegisterRequestProcessor extends SIPRequestProcessorParent implemen private SipConfig sipConfig; @Autowired - private SIPProcessorObserver sipProcessorObserver; + private ISIPProcessorObserver sipProcessorObserver; @Autowired private IDeviceService deviceService; diff --git a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/SubscribeRequestProcessor.java b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/SubscribeRequestProcessor.java index 4ed3afdc..b6acd7d3 100644 --- a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/SubscribeRequestProcessor.java +++ b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/SubscribeRequestProcessor.java @@ -2,7 +2,7 @@ package com.viewsh.module.video.gb28181.transmit.event.request.impl; import com.viewsh.module.video.gb28181.bean.*; import com.viewsh.module.video.gb28181.service.IPlatformService; -import com.viewsh.module.video.gb28181.transmit.SIPProcessorObserver; +import com.viewsh.module.video.gb28181.transmit.ISIPProcessorObserver; import com.viewsh.module.video.gb28181.transmit.SIPSender; import com.viewsh.module.video.gb28181.transmit.event.request.ISIPRequestProcessor; import com.viewsh.module.video.gb28181.transmit.event.request.SIPRequestProcessorParent; @@ -36,7 +36,7 @@ public class SubscribeRequestProcessor extends SIPRequestProcessorParent impleme private final String method = "SUBSCRIBE"; @Autowired - private SIPProcessorObserver sipProcessorObserver; + private ISIPProcessorObserver sipProcessorObserver; @Autowired private SubscribeHolder subscribeHolder; diff --git a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/info/InfoRequestProcessor.java b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/info/InfoRequestProcessor.java index 22eadd30..df18da4d 100644 --- a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/info/InfoRequestProcessor.java +++ b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/info/InfoRequestProcessor.java @@ -5,7 +5,7 @@ import com.viewsh.module.video.gb28181.bean.*; import com.viewsh.module.video.gb28181.event.SipSubscribe; import com.viewsh.module.video.gb28181.service.*; import com.viewsh.module.video.gb28181.session.SipInviteSessionManager; -import com.viewsh.module.video.gb28181.transmit.SIPProcessorObserver; +import com.viewsh.module.video.gb28181.transmit.ISIPProcessorObserver; import com.viewsh.module.video.gb28181.transmit.cmd.impl.SIPCommander; import com.viewsh.module.video.gb28181.transmit.event.request.ISIPRequestProcessor; import com.viewsh.module.video.gb28181.transmit.event.request.SIPRequestProcessorParent; @@ -35,7 +35,7 @@ public class InfoRequestProcessor extends SIPRequestProcessorParent implements I private final String method = "INFO"; @Autowired - private SIPProcessorObserver sipProcessorObserver; + private ISIPProcessorObserver sipProcessorObserver; @Autowired private IPlatformService platformService; diff --git a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/message/MessageRequestProcessor.java b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/message/MessageRequestProcessor.java index ab541716..f7ce4468 100644 --- a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/message/MessageRequestProcessor.java +++ b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/request/impl/message/MessageRequestProcessor.java @@ -8,7 +8,7 @@ import com.viewsh.module.video.gb28181.event.SipSubscribe; import com.viewsh.module.video.gb28181.event.sip.SipEvent; import com.viewsh.module.video.gb28181.service.IPlatformService; import com.viewsh.module.video.gb28181.session.SipInviteSessionManager; -import com.viewsh.module.video.gb28181.transmit.SIPProcessorObserver; +import com.viewsh.module.video.gb28181.transmit.ISIPProcessorObserver; import com.viewsh.module.video.gb28181.transmit.event.request.ISIPRequestProcessor; import com.viewsh.module.video.gb28181.transmit.event.request.SIPRequestProcessorParent; import com.viewsh.module.video.gb28181.utils.SipUtils; @@ -40,7 +40,7 @@ public class MessageRequestProcessor extends SIPRequestProcessorParent implement private static final Map messageHandlerMap = new ConcurrentHashMap<>(); @Autowired - private SIPProcessorObserver sipProcessorObserver; + private ISIPProcessorObserver sipProcessorObserver; @Autowired private IPlatformService platformService; diff --git a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/response/impl/ByeResponseProcessor.java b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/response/impl/ByeResponseProcessor.java index 086a8a22..fcd52517 100644 --- a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/response/impl/ByeResponseProcessor.java +++ b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/response/impl/ByeResponseProcessor.java @@ -1,6 +1,6 @@ package com.viewsh.module.video.gb28181.transmit.event.response.impl; -import com.viewsh.module.video.gb28181.transmit.SIPProcessorObserver; +import com.viewsh.module.video.gb28181.transmit.ISIPProcessorObserver; import com.viewsh.module.video.gb28181.transmit.event.response.SIPResponseProcessorAbstract; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -18,7 +18,7 @@ public class ByeResponseProcessor extends SIPResponseProcessorAbstract { private final String method = "BYE"; @Autowired - private SIPProcessorObserver sipProcessorObserver; + private ISIPProcessorObserver sipProcessorObserver; @Override public void afterPropertiesSet() throws Exception { diff --git a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/response/impl/CancelResponseProcessor.java b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/response/impl/CancelResponseProcessor.java index 4014cf4c..967fba7f 100644 --- a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/response/impl/CancelResponseProcessor.java +++ b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/response/impl/CancelResponseProcessor.java @@ -1,6 +1,6 @@ package com.viewsh.module.video.gb28181.transmit.event.response.impl; -import com.viewsh.module.video.gb28181.transmit.SIPProcessorObserver; +import com.viewsh.module.video.gb28181.transmit.ISIPProcessorObserver; import com.viewsh.module.video.gb28181.transmit.event.response.SIPResponseProcessorAbstract; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -18,7 +18,7 @@ public class CancelResponseProcessor extends SIPResponseProcessorAbstract { private final String method = "CANCEL"; @Autowired - private SIPProcessorObserver sipProcessorObserver; + private ISIPProcessorObserver sipProcessorObserver; @Override public void afterPropertiesSet() throws Exception { diff --git a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/response/impl/InviteResponseProcessor.java b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/response/impl/InviteResponseProcessor.java index f6f32635..61cef968 100644 --- a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/response/impl/InviteResponseProcessor.java +++ b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/response/impl/InviteResponseProcessor.java @@ -1,7 +1,7 @@ package com.viewsh.module.video.gb28181.transmit.event.response.impl; import com.viewsh.module.video.gb28181.bean.Gb28181Sdp; -import com.viewsh.module.video.gb28181.transmit.SIPProcessorObserver; +import com.viewsh.module.video.gb28181.transmit.ISIPProcessorObserver; import com.viewsh.module.video.gb28181.transmit.SIPSender; import com.viewsh.module.video.gb28181.transmit.cmd.SIPRequestHeaderProvider; import com.viewsh.module.video.gb28181.transmit.event.response.SIPResponseProcessorAbstract; @@ -37,7 +37,7 @@ public class InviteResponseProcessor extends SIPResponseProcessorAbstract { private final String method = "INVITE"; @Autowired - private SIPProcessorObserver sipProcessorObserver; + private ISIPProcessorObserver sipProcessorObserver; @Autowired private SIPSender sipSender; diff --git a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/response/impl/RegisterResponseProcessor.java b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/response/impl/RegisterResponseProcessor.java index 2425a831..b304c982 100644 --- a/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/response/impl/RegisterResponseProcessor.java +++ b/viewsh-module-video/viewsh-module-video-server/src/main/java/com/viewsh/module/video/gb28181/transmit/event/response/impl/RegisterResponseProcessor.java @@ -5,7 +5,7 @@ import com.viewsh.module.video.gb28181.bean.SipTransactionInfo; import com.viewsh.module.video.gb28181.event.SipSubscribe; import com.viewsh.module.video.gb28181.event.sip.SipEvent; import com.viewsh.module.video.gb28181.service.IPlatformService; -import com.viewsh.module.video.gb28181.transmit.SIPProcessorObserver; +import com.viewsh.module.video.gb28181.transmit.ISIPProcessorObserver; import com.viewsh.module.video.gb28181.transmit.cmd.ISIPCommanderForPlatform; import com.viewsh.module.video.gb28181.transmit.event.response.SIPResponseProcessorAbstract; import com.viewsh.module.video.storager.IRedisCatchStorage; @@ -39,7 +39,7 @@ public class RegisterResponseProcessor extends SIPResponseProcessorAbstract { private IRedisCatchStorage redisCatchStorage; @Autowired - private SIPProcessorObserver sipProcessorObserver; + private ISIPProcessorObserver sipProcessorObserver; @Autowired private IPlatformService platformService;