From 4351b74a917658ae84f4df2246b6840044d19626 Mon Sep 17 00:00:00 2001 From: redkale Date: Fri, 6 Oct 2023 22:13:42 +0800 Subject: [PATCH] cluster --- src/main/java/org/redkale/boot/Application.java | 6 ++++-- src/main/java/org/redkale/cluster/ClusterAgent.java | 3 +++ 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/redkale/boot/Application.java b/src/main/java/org/redkale/boot/Application.java index 806075ea0..62fc9b793 100644 --- a/src/main/java/org/redkale/boot/Application.java +++ b/src/main/java/org/redkale/boot/Application.java @@ -1171,8 +1171,10 @@ public final class Application { this.resourceFactory.inject(agent); agent.init(agent.getConfig()); this.resourceFactory.register(agent.getName(), MessageAgent.class, agent); - this.resourceFactory.register(agent.getName(), HttpMessageClient.class, agent.getHttpMessageClient()); - //this.resourceFactory.register(agent.getName(), SncpMessageClient.class, agent.getSncpMessageClient()); //不需要给开发者使用 + if (this.clusterAgent == null) { + this.resourceFactory.register(agent.getName(), HttpMessageClient.class, agent.getHttpMessageClient()); + //this.resourceFactory.register(agent.getName(), SncpMessageClient.class, agent.getSncpMessageClient()); //不需要给开发者使用 + } } logger.info("MessageAgent init in " + (System.currentTimeMillis() - s) + " ms"); } diff --git a/src/main/java/org/redkale/cluster/ClusterAgent.java b/src/main/java/org/redkale/cluster/ClusterAgent.java index 5db0096cb..7382fb565 100644 --- a/src/main/java/org/redkale/cluster/ClusterAgent.java +++ b/src/main/java/org/redkale/cluster/ClusterAgent.java @@ -171,6 +171,9 @@ public abstract class ClusterAgent { } protected boolean canRegister(NodeServer ns, String protocol, Service service) { + if (service.getClass().getAnnotation(Component.class) != null) { + return false; + } if ("SNCP".equalsIgnoreCase(protocol) && service.getClass().getAnnotation(Local.class) != null) { return false; }