rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ding...@apache.org
Subject [rocketmq-client-go] branch master updated: fix the bug caused in HA cluster in consumer (#723)
Date Fri, 10 Sep 2021 03:22:06 GMT
This is an automated email from the ASF dual-hosted git repository.

dinglei 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 4065610  fix the bug caused in HA cluster in consumer (#723)
4065610 is described below

commit 406561060cb7d27c84df7f146a5ef003122c9cda
Author: guyinyou <36399867+guyinyou@users.noreply.github.com>
AuthorDate: Fri Sep 10 11:20:40 2021 +0800

    fix the bug caused in HA cluster in consumer (#723)
---
 consumer/push_consumer.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
index 08a1048..66bf367 100644
--- a/consumer/push_consumer.go
+++ b/consumer/push_consumer.go
@@ -106,7 +106,7 @@ func NewPushConsumer(opts ...Option) (*pushConsumer, error) {
 	if err != nil {
 		return nil, err
 	}
-
+	dc.namesrv = dc.option.ClientOptions.Namesrv
 	p := &pushConsumer{
 		defaultConsumer: dc,
 		subscribedTopic: make(map[string]string, 0),

Mime
View raw message