增加接收Bye请求后停止向上级推流功能

lawrencehj

2021-03-10 2c1dbe63de3d370d0b0f20fea474326e88b9ca23

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

@@ -22,12 +22,9 @@
@Component

public class AckRequestProcessor extends SIPRequestAbstractProcessor {



    //@Autowired

    private IRedisCatchStorage redisCatchStorage;



   //@Autowired

   private ZLMRTPServerFactory zlmrtpServerFactory;





   /**   

    * 处理  ACK请求

@@ -49,6 +46,8 @@
         String is_Udp = sendRtpItem.isTcp() ? "0" : "1";

         String deviceId = sendRtpItem.getDeviceId();

         StreamInfo streamInfo = redisCatchStorage.queryPlayByDevice(deviceId, channelId);

         sendRtpItem.setStreamId(streamInfo.getStreamId());

         redisCatchStorage.updateSendRTPSever(sendRtpItem);

         System.out.println(platformGbId);

         System.out.println(channelId);

         Map<String, Object> param = new HashMap<>();

@@ -113,5 +112,4 @@
   public void setZlmrtpServerFactory(ZLMRTPServerFactory zlmrtpServerFactory) {

      this.zlmrtpServerFactory = zlmrtpServerFactory;

   }



}