From 8f3a9a62978020e28f95eb9cf117303211144c14 Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Thu, 16 Jul 2020 17:50:04 +0800 Subject: [PATCH] --- src/org/redkale/cluster/ClusterAgent.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/org/redkale/cluster/ClusterAgent.java b/src/org/redkale/cluster/ClusterAgent.java index afdd8ffc5..3fce2424b 100644 --- a/src/org/redkale/cluster/ClusterAgent.java +++ b/src/org/redkale/cluster/ClusterAgent.java @@ -108,14 +108,14 @@ public abstract class ClusterAgent { for (Service service : localServices) { if (!canRegister(protocol, service)) continue; register(ns, protocol, service); - ClusterEntry entry = new ClusterEntry(ns, protocol, service); - localEntrys.put(entry.serviceid, entry); + ClusterEntry htentry = new ClusterEntry(ns, protocol, service); + localEntrys.put(htentry.serviceid, htentry); if (protocol.toLowerCase().startsWith("http")) { MessageMultiConsumer mmc = service.getClass().getAnnotation(MessageMultiConsumer.class); if (mmc != null) { register(ns, "mqtp", service); ClusterEntry mqentry = new ClusterEntry(ns, "mqtp", service); - localEntrys.put(entry.serviceid, mqentry); + localEntrys.put(mqentry.serviceid, mqentry); } } }