This is an automated email from the ASF dual-hosted git repository.
healchow pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.
from af2f854 [INLONG-2993][Manager] Check whether the MQ info is NULL to
avoid NPE (#2994)
add a3ca595 [INLONG-2989][TubeMQ] Fix the coding style problem of TubeMQ
Go SDK (#2995)
No new revisions were added by this update.
Summary of changes:
.../tubemq-client-twins/tubemq-client-go/README.md | 2 +-
.../tubemq-client-go/client/consumer_impl.go | 48 ++++++++++++------
.../tubemq-client-go/client/message.go | 1 +
.../tubemq-client-go/client/peer.go | 1 +
.../tubemq-client-go/codec/tubemq_codec.go | 5 +-
.../tubemq-client-go/config/config.go | 36 +++++++++-----
.../tubemq-client-go/example/consumer.go | 5 +-
.../example/multi_routine_consumer.go | 5 +-
.../tubemq-client-go/flowctrl/handler.go | 1 +
.../tubemq-client-go/log/logger.go | 1 +
.../tubemq-client-go/metadata/consumer_event.go | 1 +
.../tubemq-client-go/metadata/partition.go | 8 ++-
.../tubemq-client-go/multiplexing/multiplexing.go | 3 +-
.../tubemq-client-go/remote/remote.go | 15 ++++--
.../tubemq-client-go/rpc/broker.go | 15 ++++--
.../tubemq-client-go/rpc/client.go | 27 ++++++----
.../tubemq-client-go/rpc/master.go | 9 ++--
.../tubemq-client-go/selector/ip_selector_test.go | 24 ++++-----
.../tubemq-client-go/tdmsg/bin_msg.go | 33 ++++++++-----
.../tubemq-client-go/tdmsg/td_msg.go | 57 +++++++++++++++-------
.../tubemq-client-go/util/util.go | 5 +-
.../tubemq-client-go/util/util_test.go | 4 +-
22 files changed, 203 insertions(+), 103 deletions(-)
