This is an automated email from the ASF dual-hosted git repository.
wenfeng pushed a change to branch native
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git.
from bda9f6a [ISSUE #328] message add GetProperties func (#325)
add fdbb58a feat(client): add mutex for rebalance (#316)
No new revisions were added by this update.
Summary of changes:
consumer/consumer.go | 10 ++++------
consumer/process_queue.go | 40 +++++++++++++++++++++++++++++++---------
internal/client.go | 3 +++
3 files changed, 38 insertions(+), 15 deletions(-)
