[rocketmq-client-go] branch master updated: fix panic when pullconsumer started.

[ji...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jianhaixu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git


The following commit(s) were added to refs/heads/master by this push:
     new ac29854  fix panic when pullconsumer started.
     new f9b98f4  Merge pull request #524 from Demogorgon314/master
ac29854 is described below

commit ac298546b08c1e5198629bf6f5f2f78990a5451d
Author: Demogorgon314 <wa...@gmail.com>
AuthorDate: Thu Aug 13 21:40:20 2020 +0800

    fix panic when pullconsumer started.
---
 consumer/pull_consumer.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/consumer/pull_consumer.go b/consumer/pull_consumer.go
index 0523f08..3a54194 100644
--- a/consumer/pull_consumer.go
+++ b/consumer/pull_consumer.go
@@ -81,6 +81,7 @@ func NewPullConsumer(options ...Option) (*defaultPullConsumer, error) {
 		return nil, errors.Wrap(err, "new Namesrv failed.")
 	}
 
+	defaultOpts.Namesrv = srvs
 	dc := &defaultConsumer{
 		client:        internal.GetOrNewRocketMQClient(defaultOpts.ClientOptions, nil),
 		consumerGroup: defaultOpts.GroupName,