| | |
|---|
| | | // String streamMode = device.getStreamMode().toUpperCase();
|
|---|
| | |
|
|---|
| | | logger.info("{} 分配的ZLM为: {} [{}:{}]", stream, mediaServerItem.getId(), mediaServerItem.getIp(), ssrcInfo.getPort());
|
|---|
| | | HookSubscribeForStreamChange hookSubscribe = HookSubscribeFactory.on_stream_changed("rtp", stream, true, "rtmp", mediaServerItem.getId());
|
|---|
| | | HookSubscribeForStreamChange hookSubscribe = HookSubscribeFactory.on_stream_changed("rtp", stream, true, "rtsp", mediaServerItem.getId());
|
|---|
| | | subscribe.addSubscribe(hookSubscribe, (MediaServerItem mediaServerItemInUse, JSONObject json)->{
|
|---|
| | | if (event != null) {
|
|---|
| | | event.response(mediaServerItemInUse, json);
|
|---|
| | |
|---|
| | |
|
|---|
| | | CallIdHeader callIdHeader = device.getTransport().equals("TCP") ? tcpSipProvider.getNewCallId()
|
|---|
| | | : udpSipProvider.getNewCallId();
|
|---|
| | | HookSubscribeForStreamChange hookSubscribe = HookSubscribeFactory.on_stream_changed("rtp", ssrcInfo.getStream(), true, "rtmp", mediaServerItem.getId());
|
|---|
| | | HookSubscribeForStreamChange hookSubscribe = HookSubscribeFactory.on_stream_changed("rtp", ssrcInfo.getStream(), true, "rtsp", mediaServerItem.getId());
|
|---|
| | | // 添加订阅
|
|---|
| | | subscribe.addSubscribe(hookSubscribe, (MediaServerItem mediaServerItemInUse, JSONObject json)->{
|
|---|
| | | if (hookEvent != null) {
|
|---|
| | |
|---|
| | |
|
|---|
| | | private void sendNotify(Device device, String catalogXmlContent,
|
|---|
| | | SubscribeInfo subscribeInfo, SipSubscribe.Event errorEvent, SipSubscribe.Event okEvent )
|
|---|
| | | throws NoSuchFieldException, IllegalAccessException, SipException, ParseException {
|
|---|
| | | throws SipException, ParseException {
|
|---|
| | | MessageFactoryImpl messageFactory = (MessageFactoryImpl) sipFactory.createMessageFactory();
|
|---|
| | | String characterSet = device.getCharset();
|
|---|
| | | // 设置编码， 防止中文乱码
|
|---|
