| | |
|---|
| | | @Override |
|---|
| | | public void process(RequestEvent evt) { |
|---|
| | | CallIdHeader callIdHeader = (CallIdHeader)evt.getRequest().getHeader(CallIdHeader.NAME); |
|---|
| | | dynamicTask.stop(callIdHeader.getCallId()); |
|---|
| | | String fromUserId = ((SipURI) ((HeaderAddress) evt.getRequest().getHeader(FromHeader.NAME)).getAddress().getURI()).getUser(); |
|---|
| | | String toUserId = ((SipURI) ((HeaderAddress) evt.getRequest().getHeader(ToHeader.NAME)).getAddress().getURI()).getUser(); |
|---|
| | | logger.info("[收到ACK]： 来自->{}", fromUserId); |
|---|
| | |
|---|
| | | } |
|---|
| | | // tcp主动时，此时是级联下级平台，在回复200ok时，本地已经请求zlm开启监听，跳过下面步骤 |
|---|
| | | if (sendRtpItem.isTcpActive()) { |
|---|
| | | logger.info("收到ACK，rtp/{} TCP主动方式后续处理", sendRtpItem.getStreamId()); |
|---|
| | | logger.info("收到ACK，rtp/{} TCP主动方式后续处理", sendRtpItem.getStream()); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | String is_Udp = sendRtpItem.isTcp() ? "0" : "1"; |
|---|
| | | MediaServerItem mediaInfo = mediaServerService.getOne(sendRtpItem.getMediaServerId()); |
|---|
| | | logger.info("收到ACK，rtp/{}开始向上级推流, 目标={}:{}，SSRC={}, 协议:{}", |
|---|
| | | sendRtpItem.getStream(), |
|---|
