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 <[email protected]> AuthorDate: Wed Jun 9 10:28:28 2021 +0800 init the channel Signed-off-by: Zijie Lu <[email protected]> --- 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)
