You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by xu...@apache.org on 2019/07/16 04:27:51 UTC

[rocketmq-client-go] 01/01: [ISSUE #114] Add orderly consume

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

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

commit b95e8876d93082ba1147ef4ba61dccd1c4ae940a
Merge: 25f4036 0b80814
Author: jonnxu <jo...@163.com>
AuthorDate: Tue Jul 16 12:27:45 2019 +0800

    [ISSUE #114] Add orderly consume
    
    [ISSUE #114] add orderly consume. resolve #114

 consumer/consumer.go                               |  59 +++--
 .../producer/simple/main.go => consumer/lock.go    |  45 ++--
 consumer/option.go                                 |  22 +-
 consumer/process_queue.go                          |  43 +++-
 consumer/push_consumer.go                          | 241 ++++++++++++++++++---
 .../{producer/simple => consumer/orderly}/main.go  |  43 ++--
 examples/producer/simple/main.go                   |   2 +-
 internal/client.go                                 |   2 +-
 primitive/ctx.go                                   |  23 ++
 primitive/message.go                               |   4 +-
 10 files changed, 361 insertions(+), 123 deletions(-)