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/09 05:17:28 UTC

[rocketmq-client-go] 01/01: [ISSUE #101] Add QueueSelector in producer

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 136d7921a54aa5e037fe303e3d57d4577272705d
Merge: 45cb340 2afa740
Author: jonnxu <jo...@163.com>
AuthorDate: Tue Jul 9 13:17:23 2019 +0800

    [ISSUE #101] Add QueueSelector in producer

 examples/producer/async/main.go |  3 +-
 internal/producer/producer.go   | 17 ++++----
 primitive/message.go            |  4 ++
 primitive/options.go            | 20 ++++++---
 primitive/selector.go           | 89 +++++++++++++++++++++++++++++++++++++++++
 primitive/selector_test.go      | 43 ++++++++++++++++++++
 primitive/strategy.go           |  2 +-
 7 files changed, 163 insertions(+), 15 deletions(-)