搭配zgyw，实现gb28181
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
648540858
2022-12-19 16f3b0553d5ea1dd891b56b93e3e13da950cf4dd 
 src/main/java/com/genersoft/iot/vmp/gb28181/event/SipSubscribe.java


@@ -1,5 +1,6 @@


package com.genersoft.iot.vmp.gb28181.event;




import com.genersoft.iot.vmp.conf.exception.SsrcTransactionNotFoundException;


import com.genersoft.iot.vmp.gb28181.bean.DeviceNotFoundEvent;


import gov.nist.javax.sip.message.SIPRequest;


import org.slf4j.Logger;


@@ -7,10 +8,12 @@


import org.springframework.scheduling.annotation.Scheduled;


import org.springframework.stereotype.Component;




import javax.sip.*;


import javax.sip.DialogTerminatedEvent;


import javax.sip.ResponseEvent;


import javax.sip.TimeoutEvent;


import javax.sip.TransactionTerminatedEvent;


import javax.sip.header.CallIdHeader;


import javax.sip.message.Response;


import java.text.ParseException;


import java.time.Instant;


import java.util.Map;


import java.util.concurrent.ConcurrentHashMap;


@@ -29,6 +32,7 @@


    private Map<String, SipSubscribe.Event> okSubscribes = new ConcurrentHashMap<>();




    private Map<String, Instant> okTimeSubscribes = new ConcurrentHashMap<>();




    private Map<String, Instant> errorTimeSubscribes = new ConcurrentHashMap<>();




    //    @Scheduled(cron="*/5 * * * * ?")   //每五秒执行一次


@@ -57,7 +61,7 @@


        logger.debug("errorSubscribes.size:{}",errorSubscribes.size());


    }




    public interface Event { void response(EventResult eventResult) ;


    public interface Event { void response(EventResult eventResult);


    }




    /**