修改group.topic后缀名

This commit is contained in:
liuxiaobo 2025-06-14 12:32:33 +08:00
parent 7038f76780
commit 9784689c1e

View File

@ -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 {