fix: consume type compatible with protocol (#387)

apache · Jan 15, 2020 · 27e707e · 27e707e
1 parent 8f76a40
commit 27e707e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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 = "*"
 )