You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by go...@apache.org on 2021/06/15 02:00:01 UTC
[incubator-inlong] 08/09: init the channel
This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a commit to branch INLONG-25
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
commit 07e73aebc27eddd7a05fcb12d56aa44bb56f7122
Author: Zijie Lu <ws...@gmail.com>
AuthorDate: Wed Jun 9 10:28:28 2021 +0800
init the channel
Signed-off-by: Zijie Lu <ws...@gmail.com>
---
tubemq-client-twins/tubemq-client-go/client/consumer_impl.go | 1 +
1 file changed, 1 insertion(+)
diff --git a/tubemq-client-twins/tubemq-client-go/client/consumer_impl.go b/tubemq-client-twins/tubemq-client-go/client/consumer_impl.go
index 674f810..30b93b4 100644
--- a/tubemq-client-twins/tubemq-client-go/client/consumer_impl.go
+++ b/tubemq-client-twins/tubemq-client-go/client/consumer_impl.go
@@ -92,6 +92,7 @@ func NewConsumer(config *config.Config) (Consumer, error) {
client: client,
visitToken: util.InvalidValue,
unreportedTimes: 0,
+ done: make(chan struct{}),
}
c.subInfo.SetClientID(clientID)
hbm := newHBManager(c)