| commit | 27e707e80d363c32ffbfdb9beffd596fd3369ef2 | [log] [tgz] |
|---|---|---|
| author | Xin Zhang <ahjdzx@users.noreply.github.com> | Wed Jan 15 10:43:47 2020 +0800 |
| committer | wenfeng <sxian.wang@gmail.com> | Wed Jan 15 10:43:47 2020 +0800 |
| tree | d994a5a3797fee498119b482ac5cda1c40f25c9b | |
| parent | 8f76a40bb4981a947212fcf490b3f61344a19417 [diff] |
fix: consume type compatible with protocol (#387)
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 @@ type ConsumeType string const ( - _PullConsume = ConsumeType("pull") - _PushConsume = ConsumeType("push") + _PullConsume = ConsumeType("CONSUME_ACTIVELY") + _PushConsume = ConsumeType("CONSUME_PASSIVELY") _SubAll = "*" )