From d4ae8194eb87271423aba24bab0f0d815d5ffdc1 Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: 星期二, 13 十月 2020 14:46:47 +0800 Subject: [PATCH] 离在线状态样式修改 修复未回复200ok导致catalog一直发送的bug 修改点播接口未收到视频后回复 --- src/main/java/com/genersoft/iot/vmp/gb28181/transmit/request/impl/SubscribeRequestProcessor.java | 18 +++++++----------- 1 files changed, 7 insertions(+), 11 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/request/impl/SubscribeRequestProcessor.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/request/impl/SubscribeRequestProcessor.java index b0c05a8..010659e 100644 --- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/request/impl/SubscribeRequestProcessor.java +++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/request/impl/SubscribeRequestProcessor.java @@ -10,18 +10,14 @@ import javax.sip.message.Request; import javax.sip.message.Response; -import org.springframework.stereotype.Component; - -import com.genersoft.iot.vmp.gb28181.SipLayer; -import com.genersoft.iot.vmp.gb28181.transmit.request.ISIPRequestProcessor; +import com.genersoft.iot.vmp.gb28181.transmit.request.SIPRequestAbstractProcessor; /** * @Description:SUBSCRIBE璇锋眰澶勭悊鍣� - * @author: songww + * @author: swwheihei * @date: 2020骞�5鏈�3鏃� 涓嬪崍5:31:20 */ -@Component -public class SubscribeRequestProcessor implements ISIPRequestProcessor { +public class SubscribeRequestProcessor extends SIPRequestAbstractProcessor { /** * 澶勭悊SUBSCRIBE璇锋眰 @@ -32,18 +28,18 @@ * @param config */ @Override - public void process(RequestEvent evt, SipLayer layer) { + public void process(RequestEvent evt) { Request request = evt.getRequest(); try { Response response = null; - response = layer.getMessageFactory().createResponse(200, request); + response = getMessageFactory().createResponse(200, request); if (response != null) { - ExpiresHeader expireHeader = layer.getHeaderFactory().createExpiresHeader(30); + ExpiresHeader expireHeader = getHeaderFactory().createExpiresHeader(30); response.setExpires(expireHeader); } System.out.println("response : " + response.toString()); - ServerTransaction transaction = layer.getServerTransaction(evt); + ServerTransaction transaction = getServerTransaction(evt); if (transaction != null) { transaction.sendResponse(response); transaction.terminate(); -- Gitblit v1.8.0