From 9784689c1e5e6c484e9f30c28016322e93cbd49e Mon Sep 17 00:00:00 2001 From: liuxiaobo <1224730913@qq.com> Date: Sat, 14 Jun 2025 12:32:33 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9group.topic=E5=90=8E=E7=BC=80?= =?UTF-8?q?=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- service/topic.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/service/topic.go b/service/topic.go index 6d19865..24852b6 100644 --- a/service/topic.go +++ b/service/topic.go @@ -1,9 +1,10 @@ package service const ( - extTopic = ".topic" - extGroup = ".group" - extRpcTopic = ".rpc.topic" + extTopic = ".topic" + extGroupTopic = ".group.topic" + extGroup = ".group" + extRpcTopic = ".rpc.topic" ) // 每个服务都有自己的服务topic @@ -25,7 +26,7 @@ func RpcTopicEx(serviceName string) string { } func GroupTopic(s IService) string { - return s.Type() + extTopic + return s.Type() + extGroupTopic } func GroupQueue(s IService) string {