对级联点播信令进行处理

panlinlin

2021-03-02 2f165d595af3565bd17612ee0f5866ace8ab43f4

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/request/impl/AckRequestProcessor.java

@@ -1,16 +1,9 @@
package com.genersoft.iot.vmp.gb28181.transmit.request.impl;



import javax.sip.Dialog;

import javax.sip.InvalidArgumentException;

import javax.sip.RequestEvent;

import javax.sip.ServerTransaction;

import javax.sip.SipException;

import javax.sip.*;

import javax.sip.message.Request;



import org.springframework.stereotype.Component;



import com.genersoft.iot.vmp.gb28181.SipLayer;

import com.genersoft.iot.vmp.gb28181.transmit.request.ISIPRequestProcessor;

import com.genersoft.iot.vmp.gb28181.transmit.request.SIPRequestAbstractProcessor;



import gov.nist.javax.sip.header.CSeq;



@@ -19,21 +12,22 @@
 * @author: swwheihei

 * @date:   2020年5月3日 下午5:31:45     

 */

@Component

public class AckRequestProcessor implements ISIPRequestProcessor {

public class AckRequestProcessor extends SIPRequestAbstractProcessor {

   

   /**   

    * 处理  ACK请求

    * 

    * @param evt

    * @param layer

    * @param transaction

    * @param config    
    */  
    */

   @Override

   public void process(RequestEvent evt, SipLayer layer) {

   public void process(RequestEvent evt) {

      Request request = evt.getRequest();

      Dialog dialog = evt.getDialog();

      DialogState state = dialog.getState();

      if (dialog == null) return;

      if (request.getMethod().equals(Request.INVITE) && dialog.getState()== DialogState.CONFIRMED) {

         // TODO 查询并开始推流

      }

      try {

         Request ackRequest = null;

         CSeq csReq = (CSeq) request.getHeader(CSeq.NAME);