[集群] 修复语音对讲支持

master
648540858 2025-01-21 17:37:57 +08:00
parent ba27819874
commit 2297a2ffa7
1 changed files with 1 additions and 0 deletions

View File

@ -246,6 +246,7 @@ public class RedisRpcPlayServiceImpl implements IRedisRpcPlayService {
jsonObject.put("channelDeviceId", channelDeviceId); jsonObject.put("channelDeviceId", channelDeviceId);
jsonObject.put("broadcastMode", broadcastMode); jsonObject.put("broadcastMode", broadcastMode);
RedisRpcRequest request = buildRequest("devicePlay/audioBroadcast", jsonObject.toString()); RedisRpcRequest request = buildRequest("devicePlay/audioBroadcast", jsonObject.toString());
request.setToId(serverId);
RedisRpcResponse response = redisRpcConfig.request(request, userSetting.getPlayTimeout(), TimeUnit.SECONDS); RedisRpcResponse response = redisRpcConfig.request(request, userSetting.getPlayTimeout(), TimeUnit.SECONDS);
if (response != null && response.getStatusCode() == ErrorCode.SUCCESS.getCode()) { if (response != null && response.getStatusCode() == ErrorCode.SUCCESS.getCode()) {
return JSON.parseObject(response.getBody().toString(), AudioBroadcastResult.class); return JSON.parseObject(response.getBody().toString(), AudioBroadcastResult.class);