From ab00fe90de92502088513c6c74dbe8f91e67574c Mon Sep 17 00:00:00 2001 From: yukun Date: Fri, 5 Nov 2021 21:57:21 +0800 Subject: [PATCH] [skip ci]Add rmq_producer comment (#11345) Signed-off-by: fishpenguin --- internal/util/mqclient/rmq_producer.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/mqclient/rmq_producer.go b/internal/util/mqclient/rmq_producer.go index 2fcdeaca1c..ff2614d97f 100644 --- a/internal/util/mqclient/rmq_producer.go +++ b/internal/util/mqclient/rmq_producer.go @@ -23,6 +23,7 @@ type rmqProducer struct { p rocksmq.Producer } +// Topic returns the topic of rmq producer func (rp *rmqProducer) Topic() string { return rp.p.Topic() }