From eda65381c27403e95893501d631e31df3bca8652 Mon Sep 17 00:00:00 2001 From: yukun Date: Thu, 4 Nov 2021 20:45:17 +0800 Subject: [PATCH] [skip ci]Add rmq producer comments (#11272) 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 f34a9f6d6b..2fcdeaca1c 100644 --- a/internal/util/mqclient/rmq_producer.go +++ b/internal/util/mqclient/rmq_producer.go @@ -27,6 +27,7 @@ func (rp *rmqProducer) Topic() string { return rp.p.Topic() } +// Send send the producer messages to rocksmq func (rp *rmqProducer) Send(ctx context.Context, message *ProducerMessage) (MessageID, error) { pm := &rocksmq.ProducerMessage{Payload: message.Payload} id, err := rp.p.Send(pm)