| | |
|---|
| | | result.setEnable_audio(true);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | } else if (param.getApp().equals("broadcast")) {
|
|---|
| | | result.setEnable_audio(true);
|
|---|
| | | } else if (param.getApp().equals("talk")) {
|
|---|
| | | result.setEnable_audio(true);
|
|---|
| | | }
|
|---|
| | | if (param.getApp().equalsIgnoreCase("rtp")) {
|
|---|
| | | String receiveKey = VideoManagerConstants.WVP_OTHER_RECEIVE_RTP_INFO + userSetting.getServerId() + "_" + param.getStream();
|
|---|
| | |
|---|
| | | logger.info("[ZLM HOOK] 流注销, {}->{}->{}/{}", param.getMediaServerId(), param.getSchema(), param.getApp(), param.getStream());
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | JSONObject ret = new JSONObject();
|
|---|
| | | ret.put("code", 0);
|
|---|
| | | ret.put("msg", "success");
|
|---|
| | | MediaServerItem mediaInfo = mediaServerService.getOne(param.getMediaServerId());
|
|---|
| | | JSONObject json = (JSONObject) JSON.toJSON(param);
|
|---|
| | | taskExecutor.execute(() -> {
|
|---|
| | | ZlmHttpHookSubscribe.Event subscribe = this.subscribe.sendNotify(HookType.on_stream_changed, json);
|
|---|
| | | MediaServerItem mediaInfo = mediaServerService.getOne(param.getMediaServerId());
|
|---|
| | | if (mediaInfo == null) {
|
|---|
| | | logger.info("[ZLM HOOK] 流变化未找到ZLM, {}", param.getMediaServerId());
|
|---|
| | | return;
|
|---|
| | |
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | return HookResult.SUCCESS();
|
|---|
