From 43edb0f81464b9f2c7dbf522a463f874c7dc88bf Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Thu, 3 Sep 2020 15:01:06 +0800 Subject: [PATCH] --- src/org/redkale/mq/MessageAgent.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/org/redkale/mq/MessageAgent.java b/src/org/redkale/mq/MessageAgent.java index 4d971bfc6..dcd707d1b 100644 --- a/src/org/redkale/mq/MessageAgent.java +++ b/src/org/redkale/mq/MessageAgent.java @@ -55,7 +55,7 @@ public abstract class MessageAgent { protected ThreadHashExecutor workExecutor; - //本地Service消息接收处理器, key:respConsumer + //本地Service消息接收处理器, key:consumer protected HashMap messageNodes = new LinkedHashMap<>(); public void init(AnyValue config) { @@ -237,7 +237,7 @@ public abstract class MessageAgent { return "sncp.req." + Sncp.getResourceType(service).getSimpleName().replaceAll("Service.*$", "").toLowerCase() + (resname.isEmpty() ? "" : ("-" + resname)); } - //格式: respConsumer-sncp.req.user 不提供外部使用 + //格式: consumer-sncp.req.user 不提供外部使用 protected final String generateSncpConsumerid(String topic, Service service) { return "consumer-" + topic; } @@ -271,7 +271,7 @@ public abstract class MessageAgent { return new String[]{"http.req." + module + (resname.isEmpty() ? "" : ("-" + resname))}; } - //格式: respConsumer-http.req.user + //格式: consumer-http.req.user protected String generateHttpConsumerid(String[] topics, Service service) { String resname = Sncp.getResourceName(service); String key = Rest.getRestModule(service).toLowerCase();