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 <jonnxu@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(-)
|