From 2073ae497bda2f358fe843fea7693b1c78785a4d Mon Sep 17 00:00:00 2001 From: yukun Date: Tue, 9 Nov 2021 21:11:41 +0800 Subject: [PATCH] [skip ci]Add rmq consumer impl chan comment (#11531) Signed-off-by: fishpenguin --- internal/util/rocksmq/client/rocksmq/consumer_impl.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/rocksmq/client/rocksmq/consumer_impl.go b/internal/util/rocksmq/client/rocksmq/consumer_impl.go index d57c7e0050..12edbd603c 100644 --- a/internal/util/rocksmq/client/rocksmq/consumer_impl.go +++ b/internal/util/rocksmq/client/rocksmq/consumer_impl.go @@ -98,6 +98,7 @@ func (c *consumer) MsgMutex() chan struct{} { return c.msgMutex } +// Chan start consume goroutine and return message channel func (c *consumer) Chan() <-chan ConsumerMessage { c.startOnce.Do(func() { c.client.wg.Add(1)