You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by di...@apache.org on 2021/08/30 03:36:37 UTC
[rocketmq-client-go] branch master updated: (fix): set subversion
when #Subscribe (#720)
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 <ha...@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