[skip ci]Add rocksmq client comments (#11052)

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
pull/11054/head
yukun 2021-11-01 23:02:33 +08:00 committed by GitHub
parent 58aa8986b6
commit af7a5ca50f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 0 deletions

View File

@ -64,6 +64,7 @@ func (c *client) CreateProducer(options ProducerOptions) (Producer, error) {
return producer, nil
}
// Subscribe create a rocksmq consumer and start consume in a goroutine
func (c *client) Subscribe(options ConsumerOptions) (Consumer, error) {
// Create a consumer
if reflect.ValueOf(c.server).IsNil() {