[pulsar-client-go] branch master updated: Fix #111: set consumer options (#113)

[zh...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 9ce7c6f  Fix #111: set consumer options (#113)
9ce7c6f is described below

commit 9ce7c6fe2869e92974bab3d8444c1e08424e2e87
Author: Reugn <re...@gmail.com>
AuthorDate: Mon Dec 9 11:09:26 2019 +0200

    Fix #111: set consumer options (#113)
    
    Fixes #111
    Subscriber.Subscription() should return the subscription name instead of returns ""
---
 pulsar/consumer_impl.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pulsar/consumer_impl.go b/pulsar/consumer_impl.go
index 4ac1909..bbd09aa 100644
--- a/pulsar/consumer_impl.go
+++ b/pulsar/consumer_impl.go
@@ -114,6 +114,7 @@ func newConsumer(client *client, options ConsumerOptions) (Consumer, error) {
 func internalTopicSubscribe(client *client, options ConsumerOptions, topic string,
 	messageCh chan ConsumerMessage) (*consumer, error) {
 	consumer := &consumer{
+		options:   options,
 		messageCh: messageCh,
 		errorCh:   make(chan error),
 		log:       log.WithField("topic", topic),