[rocketmq-clients] branch master updated: fix options bug

[aaronai]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new d67cd441 fix options bug
d67cd441 is described below

commit d67cd44172a350811871cd570464e76d896429d8
Author: guyinyou <guyinyou....@alibaba-inc.com>
AuthorDate: Wed Nov 9 18:02:22 2022 +0800

    fix options bug
---
 golang/producer.go        | 3 ++-
 golang/simple_consumer.go | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/golang/producer.go b/golang/producer.go
index 2318baaa..c3ad9929 100644
--- a/golang/producer.go
+++ b/golang/producer.go
@@ -114,7 +114,8 @@ func (p *defaultProducer) wrapSendMessageRequest(pMsgs 
[]*PublishingMessage) (*v
 }
 
 var NewProducer = func(config *Config, opts ...ProducerOption) (Producer, 
error) {
-       po := &defaultProducerOptions
+       copyOpt := defaultProducerOptions
+       po := &copyOpt
        for _, opt := range opts {
                opt.apply(po)
        }
diff --git a/golang/simple_consumer.go b/golang/simple_consumer.go
index fbb88444..17029e5d 100644
--- a/golang/simple_consumer.go
+++ b/golang/simple_consumer.go
@@ -316,7 +316,8 @@ func (sc *defaultSimpleConsumer) wrapHeartbeatRequest() 
*v2.HeartbeatRequest {
 }
 
 var NewSimpleConsumer = func(config *Config, opts ...SimpleConsumerOption) 
(SimpleConsumer, error) {
-       scOpts := &defaultSimpleConsumerOptions
+       copyOpt := defaultSimpleConsumerOptions
+       scOpts := &copyOpt
        for _, opt := range opts {
                opt.apply(scOpts)
        }