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 <[email protected]>
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(-)

Reply via email to