roouzenn/wvp
Template
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

临时提交

Browse Source
This commit is contained in:
648540858
2024-08-12 09:54:50 +08:00
parent d8d9f76d89
commit bfa2c1b2e8
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/com/genersoft/iot/vmp/service/redisMsg/control/RedisRpcController.java
View File

@@ -168,7 +168,7 @@ public class RedisRpcController {
*/ */
public RedisRpcResponse onStreamOnlineEvent(RedisRpcRequest request) { public RedisRpcResponse onStreamOnlineEvent(RedisRpcRequest request) {
StreamInfo streamInfo = JSONObject.parseObject(request.getParam().toString(), StreamInfo.class); StreamInfo streamInfo = JSONObject.parseObject(request.getParam().toString(), StreamInfo.class);
log.info("[redis-rpc] 监听流上线： {}/{}", streamInfo.getApp(), streamInfo.getStream()); log.info("[redis-rpc] 监听流信息，等待流上线： {}/{}", streamInfo.getApp(), streamInfo.getStream());
// 查询本级是否有这个流 // 查询本级是否有这个流
StreamInfo streamInfoInServer = mediaServerService.getMediaByAppAndStream(streamInfo.getApp(), streamInfo.getStream()); StreamInfo streamInfoInServer = mediaServerService.getMediaByAppAndStream(streamInfo.getApp(), streamInfo.getStream());
if (streamInfoInServer != null) { if (streamInfoInServer != null) {
@@ -192,7 +192,6 @@ public class RedisRpcController {
// 手动发送结果 // 手动发送结果
sendResponse(response); sendResponse(response);
hookSubscribe.removeSubscribe(hook); hookSubscribe.removeSubscribe(hook);
}); });
return null; return null;
} }