From 552efd4b7be070d3ab84e2394071d59e82517829 Mon Sep 17 00:00:00 2001 From: yukun Date: Tue, 26 Oct 2021 21:40:24 +0800 Subject: [PATCH] [skip ci]Add comments for rocksmq producer_impl Send (#10696) Signed-off-by: fishpenguin --- internal/util/rocksmq/client/rocksmq/producer_impl.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/rocksmq/client/rocksmq/producer_impl.go b/internal/util/rocksmq/client/rocksmq/producer_impl.go index 7f72ac83a5..8fd9f5de90 100644 --- a/internal/util/rocksmq/client/rocksmq/producer_impl.go +++ b/internal/util/rocksmq/client/rocksmq/producer_impl.go @@ -45,6 +45,7 @@ func (p *producer) Topic() string { return p.topic } +// Send produce message in rocksmq func (p *producer) Send(message *ProducerMessage) (UniqueID, error) { ids, err := p.c.server.Produce(p.topic, []server.ProducerMessage{ {