From 218aebaa0fd2259693ba2d901b2728c536b9e021 Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Wed, 3 Jun 2020 22:34:10 +0800 Subject: [PATCH] --- src/org/redkale/mq/MessageAgent.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/org/redkale/mq/MessageAgent.java b/src/org/redkale/mq/MessageAgent.java index 75b5622f1..dfa3c25e5 100644 --- a/src/org/redkale/mq/MessageAgent.java +++ b/src/org/redkale/mq/MessageAgent.java @@ -180,17 +180,17 @@ public abstract class MessageAgent { return "http.req." + module.toLowerCase(); } + //格式: http.resp.node10 + public String generateHttpRespTopic() { + return "http.resp.node" + nodeid; + } + //格式: http.req.user protected String generateHttpReqTopic(Service service) { String resname = Sncp.getResourceName(service); return "http.req." + Rest.getRestName(service).toLowerCase() + (resname.isEmpty() ? "" : ("-" + resname)); } - //格式: http.resp.node10 - protected String generateHttpRespTopic() { - return "http.resp.node" + nodeid; - } - //格式: ws.resp.wsgame public String generateWebSocketRespTopic(WebSocketNode node) { return "ws.resp." + node.getName();