| | |
|---|
| | | */
|
|---|
| | | @Override
|
|---|
| | | public void playbackStreamCmd(MediaServerItem mediaServerItem, SSRCInfo ssrcInfo, Device device, String channelId,
|
|---|
| | | String startTime, String endTime,
|
|---|
| | | InviteStreamCallback inviteStreamCallback, InviteStreamCallback hookEvent,
|
|---|
| | | String startTime, String endTime, InviteStreamCallback inviteStreamCallback, InviteStreamCallback hookEvent,
|
|---|
| | | SipSubscribe.Event okEvent, SipSubscribe.Event errorEvent) throws InvalidArgumentException, SipException, ParseException {
|
|---|
| | |
|
|---|
| | |
|
|---|
| | |
|---|
| | | content.append("a=setup:active\r\n");
|
|---|
| | | content.append("a=connection:new\r\n");
|
|---|
| | | }
|
|---|
| | | } else
|
|---|
| | | {
|
|---|
| | | } else {
|
|---|
| | | if ("TCP-PASSIVE".equalsIgnoreCase(streamMode)) {
|
|---|
| | | content.append("m=video " + ssrcInfo.getPort() + " TCP/RTP/AVP 96 97 98 99\r\n");
|
|---|
| | | } else if ("TCP-ACTIVE".equalsIgnoreCase(streamMode)) {
|
|---|
| | |
|---|
| | |
|
|---|
| | | HookSubscribeForStreamChange hookSubscribe = HookSubscribeFactory.on_stream_changed("rtp", ssrcInfo.getStream(), true, null, mediaServerItem.getId());
|
|---|
| | | // 添加订阅
|
|---|
| | | subscribe.addSubscribe(hookSubscribe, (MediaServerItem mediaServerItemInUse, JSONObject json) ->
|
|---|
| | | {
|
|---|
| | | subscribe.addSubscribe(hookSubscribe, (MediaServerItem mediaServerItemInUse, JSONObject json) -> {
|
|---|
| | | hookEvent.call(new InviteStreamInfo(mediaServerItem, json,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()).getCallId(), "rtp", ssrcInfo.getStream()));
|
|---|
| | | subscribe.removeSubscribe(hookSubscribe);
|
|---|
| | | hookSubscribe.getContent().put("regist", false);
|
|---|
