From 5ec895fedcd01de72b957eed72a764dca5cc8ee9 Mon Sep 17 00:00:00 2001 From: yukun Date: Tue, 9 Nov 2021 21:13:37 +0800 Subject: [PATCH] [skip ci]Add rmq consumer impl MsgMutex comment (#11532) 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 12edbd603c..57d7ae5c5a 100644 --- a/internal/util/rocksmq/client/rocksmq/consumer_impl.go +++ b/internal/util/rocksmq/client/rocksmq/consumer_impl.go @@ -94,6 +94,7 @@ func (c *consumer) Topic() string { return c.topic } +// MsgMutex return the message mutex channel of consumer func (c *consumer) MsgMutex() chan struct{} { return c.msgMutex }