[rocketmq-client-go] branch master updated: (fix): set subversion when #Subscribe (#720)

[dinglei]

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 29d789e  (fix): set subversion when #Subscribe (#720)
29d789e is described below

commit 29d789edcaa3408e569e96e76bd71591ee66dbe7
Author: Robin Han <hanxvdov...@gmail.com>
AuthorDate: Mon Aug 30 11:36:28 2021 +0800

    (fix): set subversion when #Subscribe (#720)
---
 consumer/consumer.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/consumer/consumer.go b/consumer/consumer.go
index 42bc973..9dfc62f 100644
--- a/consumer/consumer.go
+++ b/consumer/consumer.go
@@ -993,6 +993,7 @@ func buildSubscriptionData(topic string, selector 
MessageSelector) *internal.Sub
                SubString: selector.Expression,
                ExpType:   string(selector.Type),
        }
+       subData.SubVersion = time.Now().UnixNano()
 
        if selector.Type != "" && selector.Type != TAG {
                return subData