[rocketmq] branch snode updated (3b62168 -> 0e4aa3a)

[du...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

duhengforever pushed a change to branch snode
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.


    from 3b62168  Merge pull request #748 from zongtanghu/snode
     new cb90409  Fix connection closed but not clean session issue
     new 21d18b3  Merge branch 'snode' of github.com:apache/rocketmq into snode
     new 0e4aa3a  Polish consumer offset management process, prevent queryed old offset in an random snode

The 653 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../apache/rocketmq/broker/BrokerController.java   |   6 +-
 .../broker/processor/ClientManageProcessor.java    |  51 ++++--
 .../consumer/store/RemoteBrokerOffsetStore.java    |   1 +
 .../client/exception/MQSnodeException.java         |   2 +-
 .../rocketmq/client/impl/MQClientAPIImpl.java      |  22 ++-
 .../impl/consumer/DefaultMQPushConsumerImpl.java   |   5 +-
 .../client/impl/factory/MQClientInstance.java      |  18 ++
 .../rocketmq/common/protocol/RequestCode.java      |   3 +-
 ...der.java => CreateRetryTopicRequestHeader.java} |  19 +-
 .../rocketmq/example/quickstart/Consumer.java      |   2 +-
 .../rocketmq/example/quickstart/Producer.java      |   4 +-
 .../org/apache/rocketmq/snode/SnodeController.java | 194 +++++++++++----------
 .../snode/client/ClientHousekeepingService.java    |  19 +-
 .../rocketmq/snode/client/ClientManager.java       |   3 +-
 .../snode/client/impl/ClientManagerImpl.java       |  65 ++++---
 .../snode/client/impl/SlowConsumerServiceImpl.java |   2 +-
 .../snode/offset/ConsumerOffsetManager.java        |  62 +++----
 .../snode/processor/ConsumerManageProcessor.java   |  43 ++---
 .../rocketmq/snode/service/EnodeService.java       |   9 +-
 .../snode/service/impl/EnodeServiceImpl.java       |  23 +--
 .../snode/service/impl/ScheduledServiceImpl.java   |  10 --
 .../snode/service/EnodeServiceImplTest.java        |  10 --
 .../snode/service/NnodeServiceImplTest.java        |   2 +-
 .../snode/service/SlowConsumerServiceImplTest.java |   4 +-
 24 files changed, 304 insertions(+), 275 deletions(-)
 copy common/src/main/java/org/apache/rocketmq/common/protocol/header/{DeleteSubscriptionGroupRequestHeader.java => CreateRetryTopicRequestHeader.java} (82%)