| | |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public void process(RequestEvent evt) { |
|---|
| | | logger.debug("ACK请求： {}", ((System.currentTimeMillis()))); |
|---|
| | | logger.info("ACK请求： {}", ((System.currentTimeMillis()))); |
|---|
| | | Dialog dialog = evt.getDialog(); |
|---|
| | | if (dialog == null) return; |
|---|
| | | if (dialog.getState()== DialogState.CONFIRMED) { |
|---|
| | |
|---|
| | | if (streamInfo == null) { |
|---|
| | | streamInfo = new StreamInfo(); |
|---|
| | | streamInfo.setApp(sendRtpItem.getApp()); |
|---|
| | | streamInfo.setStreamId(sendRtpItem.getStreamId()); |
|---|
| | | streamInfo.setStream(sendRtpItem.getStreamId()); |
|---|
| | | } |
|---|
| | | redisCatchStorage.updateSendRTPSever(sendRtpItem); |
|---|
| | | logger.info(platformGbId); |
|---|
| | |
|---|
| | | Map<String, Object> param = new HashMap<>(); |
|---|
| | | param.put("vhost","__defaultVhost__"); |
|---|
| | | param.put("app",streamInfo.getApp()); |
|---|
| | | param.put("stream",streamInfo.getStreamId()); |
|---|
| | | param.put("stream",streamInfo.getStream()); |
|---|
| | | param.put("ssrc", sendRtpItem.getSsrc()); |
|---|
| | | param.put("dst_url",sendRtpItem.getIp()); |
|---|
| | | param.put("dst_port", sendRtpItem.getPort()); |
|---|
