diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/event/SipSubscribe.java b/src/main/java/com/genersoft/iot/vmp/gb28181/event/SipSubscribe.java index 4245bddb..f341548e 100644 --- a/src/main/java/com/genersoft/iot/vmp/gb28181/event/SipSubscribe.java +++ b/src/main/java/com/genersoft/iot/vmp/gb28181/event/SipSubscribe.java @@ -6,6 +6,8 @@ import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import javax.sip.*; +import javax.sip.header.CallIdHeader; +import javax.sip.message.Response; import java.util.Calendar; import java.util.Date; import java.util.Map; @@ -23,6 +25,7 @@ public class SipSubscribe { private Map timeSubscribes = new ConcurrentHashMap<>(); // @Scheduled(cron="*/5 * * * * ?") //每五秒执行一次 +// @Scheduled(fixedRate= 100 * 60 * 60 ) @Scheduled(cron="0 0 * * * ?") //每小时执行一次, 每个整点 public void execute(){ logger.info("[定时任务] 清理过期的订阅信息"); @@ -58,11 +61,15 @@ public class SipSubscribe { this.event = event; if (event instanceof ResponseEvent) { ResponseEvent responseEvent = (ResponseEvent)event; - this.type = "response"; - this.msg = responseEvent.getResponse().getReasonPhrase(); - this.statusCode = responseEvent.getResponse().getStatusCode(); - this.callId = responseEvent.getDialog().getCallId().getCallId(); - this.dialog = responseEvent.getDialog(); + Response response = responseEvent.getResponse(); + this.dialog = responseEvent.getDialog(); + this.type = "response"; + if (response != null) { + this.msg = response.getReasonPhrase(); + this.statusCode = response.getStatusCode(); + } + this.callId = ((CallIdHeader)response.getHeader(CallIdHeader.NAME)).getCallId(); + }else if (event instanceof TimeoutEvent) { TimeoutEvent timeoutEvent = (TimeoutEvent)event; this.type = "timeout";