diff --git a/server/src/main/java/io/wdd/rpc/agent/OctopusAgentServiceImpl.java b/server/src/main/java/io/wdd/rpc/agent/OctopusAgentServiceImpl.java index e7b8485..802bc8c 100644 --- a/server/src/main/java/io/wdd/rpc/agent/OctopusAgentServiceImpl.java +++ b/server/src/main/java/io/wdd/rpc/agent/OctopusAgentServiceImpl.java @@ -28,7 +28,7 @@ import java.util.stream.Collectors; import static io.wdd.rpc.init.AgentStatusCacheService.ALL_AGENT_TOPIC_NAME_SET; import static io.wdd.rpc.init.AgentStatusCacheService.ALL_HEALTHY_AGENT_TOPIC_NAME_LIST; -import static io.wdd.rpc.message.handler.sync.OMessageHandlerServer.AGENT_LATEST_VERSION; +import static io.wdd.rpc.message.handler.sync.OMessageHandlerServer.LATEST_VERSION; import static io.wdd.rpc.message.handler.sync.OMessageHandlerServer.OCTOPUS_MESSAGE_FROM_AGENT; @Service @@ -133,7 +133,7 @@ public class OctopusAgentServiceImpl implements OctopusAgentService { String latestVersion = (String) redisTemplate .opsForValue() .get( - AGENT_LATEST_VERSION + LATEST_VERSION ); return latestVersion; diff --git a/server/src/main/java/io/wdd/rpc/message/handler/sync/OMessageHandlerServer.java b/server/src/main/java/io/wdd/rpc/message/handler/sync/OMessageHandlerServer.java index 35314c1..2fc6fde 100644 --- a/server/src/main/java/io/wdd/rpc/message/handler/sync/OMessageHandlerServer.java +++ b/server/src/main/java/io/wdd/rpc/message/handler/sync/OMessageHandlerServer.java @@ -23,7 +23,7 @@ public class OMessageHandlerServer { * Redis Key 用于保存Agent的最新版本 * 由 GitHubAction发送至 RabbitMQ中,然后此处获取处理,发送至Redis中 */ - public static final String AGENT_LATEST_VERSION = "AGENT_LATEST_VERSION"; + public static final String LATEST_VERSION = "LATEST_VERSION"; /** * 存储所有的从 Agent过来的 OctopusMessage * 各个业务模块需要自己手动去获取自己需要的内容 @@ -62,7 +62,7 @@ public class OMessageHandlerServer { // 获取Agent的版本信息 if (octopusMessage .getUuid() - .equals("Octopus-Server")) { + .equals("Octopus-Version")) { // 更新缓存Agent的最新版本信息 String latestVersion = (String) octopusMessage.getResult(); @@ -73,7 +73,7 @@ public class OMessageHandlerServer { redisTemplate .opsForValue() .set( - AGENT_LATEST_VERSION, + LATEST_VERSION, latestVersion );