648540858
2022-09-21 710600db6f3bd6f72a83ef75cca30953fd0f375f
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/response/impl/InviteResponseProcessor.java
@@ -5,7 +5,10 @@
import com.genersoft.iot.vmp.gb28181.transmit.SIPProcessorObserver;
import com.genersoft.iot.vmp.gb28181.transmit.event.response.SIPResponseProcessorAbstract;
import com.genersoft.iot.vmp.gb28181.utils.SipUtils;
import com.genersoft.iot.vmp.utils.GitUtil;
import gov.nist.javax.sip.ResponseEventExt;
import gov.nist.javax.sip.message.SIPResponse;
import gov.nist.javax.sip.stack.SIPClientTransaction;
import gov.nist.javax.sip.stack.SIPDialog;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -48,6 +51,9 @@
   @Autowired
   private SipFactory sipFactory;
   @Autowired
   private GitUtil gitUtil;
   @Override
   public void afterPropertiesSet() throws Exception {
      // 添加消息处理的订阅
@@ -74,7 +80,7 @@
         // 下发ack
         if (statusCode == Response.OK) {
            ResponseEventExt event = (ResponseEventExt)evt;
            SIPDialog dialog = (SIPDialog)evt.getDialog();
            SIPDialog dialog = new SIPDialog((SIPClientTransaction) event.getClientTransaction(), (SIPResponse) event.getResponse());
            CSeqHeader cseq = (CSeqHeader) response.getHeader(CSeqHeader.NAME);
            Request reqAck = dialog.createAck(cseq.getSeqNumber());
            SipURI requestURI = (SipURI) reqAck.getRequestURI();
@@ -98,7 +104,7 @@
            }
            requestURI.setPort(event.getRemotePort());
            reqAck.setRequestURI(requestURI);
            UserAgentHeader userAgentHeader = SipUtils.createUserAgentHeader(sipFactory);
            UserAgentHeader userAgentHeader = SipUtils.createUserAgentHeader(sipFactory, gitUtil);
            reqAck.addHeader(userAgentHeader);
            Address concatAddress = sipFactory.createAddressFactory().createAddress(sipFactory.createAddressFactory().createSipURI(sipConfig.getId(), sipConfig.getIp()+":"+sipConfig.getPort()));
            reqAck.addHeader(sipFactory.createHeaderFactory().createContactHeader(concatAddress));