lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2020-07-16 17:50:04 +08:00
parent e8d496b0ad
commit 8f3a9a6297
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/org/redkale/cluster/ClusterAgent.java
View File

@@ -108,14 +108,14 @@ public abstract class ClusterAgent {
for (Service service : localServices) { for (Service service : localServices) {
if (!canRegister(protocol, service)) continue; if (!canRegister(protocol, service)) continue;
register(ns, protocol, service); register(ns, protocol, service);
ClusterEntry entry = new ClusterEntry(ns, protocol, service); ClusterEntry htentry = new ClusterEntry(ns, protocol, service);
localEntrys.put(entry.serviceid, entry); localEntrys.put(htentry.serviceid, htentry);
if (protocol.toLowerCase().startsWith("http")) { if (protocol.toLowerCase().startsWith("http")) {
MessageMultiConsumer mmc = service.getClass().getAnnotation(MessageMultiConsumer.class); MessageMultiConsumer mmc = service.getClass().getAnnotation(MessageMultiConsumer.class);
if (mmc != null) { if (mmc != null) {
register(ns, "mqtp", service); register(ns, "mqtp", service);
ClusterEntry mqentry = new ClusterEntry(ns, "mqtp", service); ClusterEntry mqentry = new ClusterEntry(ns, "mqtp", service);
localEntrys.put(entry.serviceid, mqentry); localEntrys.put(mqentry.serviceid, mqentry);
} }
} }
} }