You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by do...@apache.org on 2018/12/14 02:38:37 UTC
[rocketmq-client-go] 01/01: Merge pull request #6 from
zjykzk/feature-pull-consumer
This is an automated email from the ASF dual-hosted git repository.
dongeforever pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git
commit 421de8227948e8c8c781d4693c78fbdf2c7aa31a
Merge: d4f285b 46cbaf1
Author: Zhendong Liu <zh...@yeah.net>
AuthorDate: Fri Dec 14 10:38:32 2018 +0800
Merge pull request #6 from zjykzk/feature-pull-consumer
Pull consumer with unit test
core/api.go | 9 ++
core/log.go | 50 +++++++++
core/pull_consumer.go | 225 ++++++++++++++++++++++++++++++++++++++
core/queue.go | 31 ++++++
examples/pullconsumer/consumer.go | 113 +++++++++++++++++++
5 files changed, 428 insertions(+)