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-09-03 15:01:06 +08:00
parent 1c684a4e32
commit 43edb0f814
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/mq/MessageAgent.java
View File

@@ -55,7 +55,7 @@ public abstract class MessageAgent {
protected ThreadHashExecutor workExecutor; protected ThreadHashExecutor workExecutor;
//本地Service消息接收处理器， key:respConsumer //本地Service消息接收处理器， key:consumer
protected HashMap<String, MessageConsumerNode> messageNodes = new LinkedHashMap<>(); protected HashMap<String, MessageConsumerNode> messageNodes = new LinkedHashMap<>();
public void init(AnyValue config) { 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)); 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) { protected final String generateSncpConsumerid(String topic, Service service) {
return "consumer-" + topic; return "consumer-" + topic;
} }
@@ -271,7 +271,7 @@ public abstract class MessageAgent {
return new String[]{"http.req." + module + (resname.isEmpty() ? "" : ("-" + resname))}; return new String[]{"http.req." + module + (resname.isEmpty() ? "" : ("-" + resname))};
} }
//格式: respConsumer-http.req.user //格式: consumer-http.req.user
protected String generateHttpConsumerid(String[] topics, Service service) { protected String generateHttpConsumerid(String[] topics, Service service) {
String resname = Sncp.getResourceName(service); String resname = Sncp.getResourceName(service);
String key = Rest.getRestModule(service).toLowerCase(); String key = Rest.getRestModule(service).toLowerCase();