修复级联注册消息回复的空指针异常

648540858

2021-11-16 874b37ef35104fa8067e869ddf5458053146b519

修复级联注册消息回复的空指针异常

 src/main/java/com/genersoft/iot/vmp/gb28181/event/SipSubscribe.java

@@ -6,6 +6,8 @@
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 @@
    private Map<String, Date> timeSubscribes = new ConcurrentHashMap<>();

//    @Scheduled(cron="*/5 * * * * ?")   //每五秒执行一次
//    @Scheduled(fixedRate= 100 * 60 * 60 )
    @Scheduled(cron="0 0 * * * ?")   //每小时执行一次， 每个整点
    public void execute(){
        logger.info("[定时任务] 清理过期的订阅信息");
@@ -58,11 +61,15 @@
            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";