| | |
| | | } |
| | | |
| | | @Override |
| | | public void waitePushStreamOnline(SendRtpItem sendRtpItem, CommonCallback<String> callback) { |
| | | public long waitePushStreamOnline(SendRtpItem sendRtpItem, CommonCallback<String> callback) { |
| | | logger.info("[请求所有WVP监听流上线] {}/{}", sendRtpItem.getApp(), sendRtpItem.getStream()); |
| | | // 监听流上线。 流上线直接发送sendRtpItem消息给实际的信令处理者 |
| | | HookSubscribeForStreamChange hook = HookSubscribeFactory.on_stream_changed( |
| | |
| | | } |
| | | hookSubscribe.removeSubscribe(hook); |
| | | }); |
| | | |
| | | return request.getSn(); |
| | | } |
| | | |
| | | @Override |
| | | public void stopWaitePushStreamOnline(SendRtpItem sendRtpItem) { |
| | | logger.info("[停止WVP监听流上线] {}/{}, key:{}", sendRtpItem.getApp(), sendRtpItem.getStream(), sendRtpItem); |
| | | logger.info("[停止WVP监听流上线] {}/{}", sendRtpItem.getApp(), sendRtpItem.getStream()); |
| | | HookSubscribeForStreamChange hook = HookSubscribeFactory.on_stream_changed( |
| | | sendRtpItem.getApp(), sendRtpItem.getStream(), true, "rtsp", null); |
| | | hookSubscribe.removeSubscribe(hook); |
| | |
| | | request.setToId(sendRtpItem.getServerId()); |
| | | redisRpcConfig.request(request, 10); |
| | | } |
| | | |
| | | @Override |
| | | public void removeCallback(long key) { |
| | | redisRpcConfig.removeCallback(key); |
| | | } |
| | | } |