|  |  | 
 |  |  | import com.genersoft.iot.vmp.gb28181.transmit.event.request.ISIPRequestProcessor; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.transmit.event.response.ISIPResponseProcessor; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.transmit.event.timeout.ITimeoutProcessor; | 
 |  |  | import gov.nist.javax.sip.message.SIPRequest; | 
 |  |  | import org.slf4j.Logger; | 
 |  |  | import org.slf4j.LoggerFactory; | 
 |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
 |  |  | 
 |  |  | import javax.sip.*; | 
 |  |  | import javax.sip.header.CSeqHeader; | 
 |  |  | import javax.sip.header.CallIdHeader; | 
 |  |  | import javax.sip.header.Header; | 
 |  |  | import javax.sip.message.Response; | 
 |  |  | import java.util.Map; | 
 |  |  | import java.util.concurrent.ConcurrentHashMap; | 
 |  |  | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private SipSubscribe sipSubscribe; | 
 |  |  |  | 
 |  |  |  | 
 |  |  | //    @Autowired | 
 |  |  | //    @Qualifier(value = "taskExecutor") | 
 |  |  | 
 |  |  |         Response response = responseEvent.getResponse(); | 
 |  |  |         logger.debug("\n收到响应:\n{}", responseEvent.getResponse()); | 
 |  |  |         int status = response.getStatusCode(); | 
 |  |  |         if (((status >= 200) && (status < 300)) || status == 401) { // Success! | 
 |  |  |  | 
 |  |  |         if (((status >= 200) && (status < 300)) || status == Response.UNAUTHORIZED) { // Success! | 
 |  |  |             CSeqHeader cseqHeader = (CSeqHeader) responseEvent.getResponse().getHeader(CSeqHeader.NAME); | 
 |  |  |             String method = cseqHeader.getMethod(); | 
 |  |  |             ISIPResponseProcessor sipRequestProcessor = responseProcessorMap.get(method); | 
 |  |  |             if (sipRequestProcessor != null) { | 
 |  |  |                 sipRequestProcessor.process(responseEvent); | 
 |  |  |             } | 
 |  |  |             if (responseEvent.getResponse() != null && sipSubscribe.getOkSubscribesSize() > 0 ) { | 
 |  |  |             if (status != Response.UNAUTHORIZED && responseEvent.getResponse() != null && sipSubscribe.getOkSubscribesSize() > 0 ) { | 
 |  |  |                 CallIdHeader callIdHeader = (CallIdHeader)responseEvent.getResponse().getHeader(CallIdHeader.NAME); | 
 |  |  |                 if (callIdHeader != null) { | 
 |  |  |                     SipSubscribe.Event subscribe = sipSubscribe.getOkSubscribe(callIdHeader.getCallId()); | 
 |  |  | 
 |  |  |      */ | 
 |  |  |     @Override | 
 |  |  |     public void processTimeout(TimeoutEvent timeoutEvent) { | 
 |  |  |         System.out.println("processTimeout"); | 
 |  |  |         if(timeoutProcessor != null) { | 
 |  |  |             timeoutProcessor.process(timeoutEvent); | 
 |  |  |         } | 
 |  |  | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public void processDialogTerminated(DialogTerminatedEvent dialogTerminatedEvent) { | 
 |  |  |         System.out.println("processDialogTerminated"); | 
 |  |  |         CallIdHeader callId = dialogTerminatedEvent.getDialog().getCallId(); | 
 |  |  |     } | 
 |  |  |  |