From 1ec153ad9b151ff84d5cfe91c088857a78d2734f Mon Sep 17 00:00:00 2001 From: yukun Date: Sat, 9 Oct 2021 00:03:51 +0800 Subject: [PATCH] [skip ci]Add comments for CreateProducer (#9517) Signed-off-by: fishpenguin --- internal/util/mqclient/rmq_client.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/mqclient/rmq_client.go b/internal/util/mqclient/rmq_client.go index a386f4f1ce..02af5c00ca 100644 --- a/internal/util/mqclient/rmq_client.go +++ b/internal/util/mqclient/rmq_client.go @@ -34,6 +34,7 @@ func NewRmqClient(opts rocksmq.ClientOptions) (*rmqClient, error) { return &rmqClient{client: c}, nil } +// CreateProducer creates a producer for rocksmq client func (rc *rmqClient) CreateProducer(options ProducerOptions) (Producer, error) { rmqOpts := rocksmq.ProducerOptions{Topic: options.Topic} pp, err := rc.client.CreateProducer(rmqOpts)