Thirdparty
/
wvp-GB28181-pro
mirror of https://github.com/648540858/wvp-GB28181-pro
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[集群] 修复BUG

dev/数据库统合
648540858 2025-01-03 15:43:07 +08:00
parent 232fa760e2
commit b650d5821d
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/genersoft/iot/vmp/service/redisMsg/service/RedisRpcServiceImpl.java
View File

@ -228,6 +228,7 @@ public class RedisRpcServiceImpl implements IRedisRpcService {
@Override @Override
public boolean updatePlatform(String serverId, Platform platform) { public boolean updatePlatform(String serverId, Platform platform) {
RedisRpcRequest request = buildRequest("platform/update", platform); RedisRpcRequest request = buildRequest("platform/update", platform);
request.setToId(serverId);
RedisRpcResponse response = redisRpcConfig.request(request, 40); RedisRpcResponse response = redisRpcConfig.request(request, 40);
return Boolean.parseBoolean(response.getBody().toString()); return Boolean.parseBoolean(response.getBody().toString());
} }
@ -239,6 +240,7 @@ public class RedisRpcServiceImpl implements IRedisRpcService {
jsonObject.put("channelIds", channelIds); jsonObject.put("channelIds", channelIds);
jsonObject.put("type", type); jsonObject.put("type", type);
RedisRpcRequest request = buildRequest("platform/catalogEventPublish", jsonObject); RedisRpcRequest request = buildRequest("platform/catalogEventPublish", jsonObject);
request.setToId(serverId);
redisRpcConfig.request(request, 100); redisRpcConfig.request(request, 100);
} }
} }