[rocketmq-client-go] branch native updated: fix: consume type compatible with protocol (#387)

[wenfeng]

This is an automated email from the ASF dual-hosted git repository.

wenfeng pushed a commit to branch native
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git


The following commit(s) were added to refs/heads/native by this push:
     new 27e707e  fix: consume type compatible with protocol (#387)
27e707e is described below

commit 27e707e80d363c32ffbfdb9beffd596fd3369ef2
Author: Xin Zhang <ahj...@users.noreply.github.com>
AuthorDate: Wed Jan 15 10:43:47 2020 +0800

    fix: consume type compatible with protocol (#387)
---
 consumer/consumer.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/consumer/consumer.go b/consumer/consumer.go
index cacbdd1..ffa6f89 100644
--- a/consumer/consumer.go
+++ b/consumer/consumer.go
@@ -61,8 +61,8 @@ const (
 type ConsumeType string
 
 const (
-       _PullConsume = ConsumeType("pull")
-       _PushConsume = ConsumeType("push")
+       _PullConsume = ConsumeType("CONSUME_ACTIVELY")
+       _PushConsume = ConsumeType("CONSUME_PASSIVELY")
 
        _SubAll = "*"
 )