Kaynağa Gözat

Merge branch 'dev' into v1.1.0

yjp 4 ay önce
ebeveyn
işleme
2a0acd3631

+ 2 - 0
framework/core/infrastructure/message_queue/message_queue.go

@@ -5,6 +5,7 @@ import "git.sxidc.com/go-framework/baize/framework/core/infrastructure/message_q
 // Subscribe 订阅
 // 参数:
 // - queue: 消息队列
+// - group: 消息组
 // - topic: 主题
 // - handler: 消息处理函数
 // 返回值:
@@ -16,6 +17,7 @@ func Subscribe(messageQueue common.MessageQueue, group string, topic string, han
 // UnSubscribe 取消订阅
 // 参数:
 // - queue: 消息队列
+// - group: 消息组
 // - topic: 主题
 // 返回值:
 // - 错误