rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xuji...@apache.org
Subject [rocketmq-client-go] 01/01: [ISSUE #114] Add orderly consume
Date Tue, 16 Jul 2019 04:27:51 GMT
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 <jonnxu@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(-)


Mime
View raw message