From b650d5821d55e668fc93d5557aa6910d6af52ae8 Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: Fri, 3 Jan 2025 15:43:07 +0800 Subject: [PATCH] =?UTF-8?q?[=E9=9B=86=E7=BE=A4]=20=E4=BF=AE=E5=A4=8DBUG?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../iot/vmp/service/redisMsg/service/RedisRpcServiceImpl.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/service/RedisRpcServiceImpl.java b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/service/RedisRpcServiceImpl.java index d420bdc8..4d6d9f1c 100644 --- a/src/main/java/com/genersoft/iot/vmp/service/redisMsg/service/RedisRpcServiceImpl.java +++ b/src/main/java/com/genersoft/iot/vmp/service/redisMsg/service/RedisRpcServiceImpl.java @@ -228,6 +228,7 @@ public class RedisRpcServiceImpl implements IRedisRpcService { @Override public boolean updatePlatform(String serverId, Platform platform) { RedisRpcRequest request = buildRequest("platform/update", platform); + request.setToId(serverId); RedisRpcResponse response = redisRpcConfig.request(request, 40); return Boolean.parseBoolean(response.getBody().toString()); } @@ -239,6 +240,7 @@ public class RedisRpcServiceImpl implements IRedisRpcService { jsonObject.put("channelIds", channelIds); jsonObject.put("type", type); RedisRpcRequest request = buildRequest("platform/catalogEventPublish", jsonObject); + request.setToId(serverId); redisRpcConfig.request(request, 100); } }