| commit | 29d789edcaa3408e569e96e76bd71591ee66dbe7 | [log] [tgz] |
|---|---|---|
| author | Robin Han <hanxvdovehx@gmail.com> | Mon Aug 30 11:36:28 2021 +0800 |
| committer | GitHub <noreply@github.com> | Mon Aug 30 11:36:28 2021 +0800 |
| tree | 9cd264fa82fe8237819b794b39635dfa6624e0d3 | |
| parent | 0922226fb3839b8f9dfc4b1713f9930a8e35c419 [diff] |
(fix): set subversion when #Subscribe (#720)
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 @@ SubString: selector.Expression, ExpType: string(selector.Type), } + subData.SubVersion = time.Now().UnixNano() if selector.Type != "" && selector.Type != TAG { return subData