This is an automated email from the ASF dual-hosted git repository.
RongtongJin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
from 5939e374 [Go] Fix resource leaks on client close (#1305)
add 54471119 feature(golang): support LiteSimpleConsumer (#1314)
No new revisions were added by this update.
Summary of changes:
golang/client.go | 8 +-
.../main.go | 32 +-
golang/lite_push_consumer.go | 123 +---
golang/lite_push_consumer_mock.go | 14 +
golang/lite_push_consumer_options.go | 34 +-
golang/lite_push_consumer_test.go | 51 +-
golang/lite_simple_consumer.go | 100 ++++
golang/lite_simple_consumer_options.go | 83 +++
golang/lite_simple_consumer_test.go | 646 +++++++++++++++++++++
golang/lite_subscription_manager.go | 268 +++++++++
golang/lite_subscription_manager_test.go | 487 ++++++++++++++++
golang/loadBalancer.go | 8 +
golang/producer.go | 12 +
golang/push_consumer.go | 24 +-
golang/simple_consumer.go | 58 +-
15 files changed, 1757 insertions(+), 191 deletions(-)
copy golang/example/consumer/{simple_consumer => lite_simple_consumer}/main.go
(74%)
create mode 100644 golang/lite_simple_consumer.go
create mode 100644 golang/lite_simple_consumer_options.go
create mode 100644 golang/lite_simple_consumer_test.go
create mode 100644 golang/lite_subscription_manager.go
create mode 100644 golang/lite_subscription_manager_test.go
