648540858
2022-05-06 5d901b5e3f033e8b04e53420d68626cbd87431c8
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/SIPRequestHeaderProvider.java
@@ -67,7 +67,7 @@
      request = sipFactory.createMessageFactory().createRequest(requestURI, Request.MESSAGE, callIdHeader, cSeqHeader, fromHeader,
            toHeader, viaHeaders, maxForwards);
      ContentTypeHeader contentTypeHeader = sipFactory.createHeaderFactory().createContentTypeHeader("APPLICATION", "MANSCDP+xml");
      ContentTypeHeader contentTypeHeader = sipFactory.createHeaderFactory().createContentTypeHeader("Application", "MANSCDP+xml");
      request.setContent(content, contentTypeHeader);
      return request;
   }
@@ -215,17 +215,26 @@
      // Event
      EventHeader eventHeader = sipFactory.createHeaderFactory().createEventHeader(event);
      int random = (int)Math.random() * 1000000000;
      eventHeader.setEventId(random + "");
      request.addHeader(eventHeader);
      ContentTypeHeader contentTypeHeader = sipFactory.createHeaderFactory().createContentTypeHeader("APPLICATION", "MANSCDP+xml");
      ContentTypeHeader contentTypeHeader = sipFactory.createHeaderFactory().createContentTypeHeader("Application", "MANSCDP+xml");
      request.setContent(content, contentTypeHeader);
      return request;
   }
   public Request createInfoRequest(Device device, StreamInfo streamInfo, String content, Long cseq)
   public Request createInfoRequest(Device device, StreamInfo streamInfo, String content)
         throws PeerUnavailableException, ParseException, InvalidArgumentException {
      Request request = null;
      Dialog dialog = streamSession.getDialog(streamInfo.getDeviceID(), streamInfo.getChannelId());
      if (streamInfo == null) {
         return null;
      }
      Dialog dialog = streamSession.getDialogByStream(streamInfo.getDeviceID(), streamInfo.getChannelId(), streamInfo.getStream());
      if (dialog == null) {
         return null;
      }
      SipURI requestLine = sipFactory.createAddressFactory().createSipURI(device.getDeviceId(),
            device.getHostAddress());
@@ -251,9 +260,8 @@
      // Forwards
      MaxForwardsHeader maxForwards = sipFactory.createHeaderFactory().createMaxForwardsHeader(70);
      if (cseq == null) {
         cseq = redisCatchStorage.getCSEQ(Request.INFO);
      }
      Long cseq = redisCatchStorage.getCSEQ(Request.INVITE);
      // ceq
      CSeqHeader cSeqHeader = sipFactory.createHeaderFactory()
            .createCSeqHeader(cseq, Request.INFO);