[rocketmq] branch snode updated (1dde4fe -> 1c26991)

[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 1dde4fe  Polish rebalance process in real push mode
     new 5b56149  add SessionManager, WillMessageService;finish CONNECT/DISCONNECT logic
     new 576dc64  fix maven-checkstyle error
     new 5f72d0d  1.remove Session and SessionManagerImpl 2.handle NPE when decode/encode between MqttMessage and RemotingCommand 3.add topic<--->subscription data 4.add subscribe and suback logic
     new 2f46644  reformat code to rmq_codestyle
     new 1c26991  Merge pull request #755 from xiangwangcheng/snode

The 898 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:
 .../trace/DefaultMQConsumerWithTraceTest.java      |  20 +--
 .../trace/DefaultMQProducerWithTraceTest.java      |  29 ++--
 .../mqtt/RetainMessage.java}                       |  35 ++--
 .../rocketmq/common/message/mqtt/WillMessage.java  |  50 +++---
 .../protocol/heartbeat/MqttSubscriptionData.java   |  89 +++++++++++
 .../remoting/transport/mqtt/MqttHeader.java        |   7 +-
 .../mqtt/MqttMessage2RemotingCommandHandler.java   |  17 +-
 .../transport/mqtt/MqttRemotingServer.java         | 157 +++++++++---------
 .../mqtt/RemotingCommand2MqttMessageHandler.java   |  31 +++-
 .../transport/mqtt/RocketMQMqttSubAckPayload.java  |  59 +++++++
 .../mqtt/RocketMQMqttSubscribePayload.java         |  67 ++++++++
 .../mqtt/RocketMQMqttUnSubscribePayload.java       |  63 ++++++++
 .../dispatcher/Message2MessageEncodeDecode.java    |   3 +-
 .../dispatcher/MqttConnectackEncodeDecode.java     |  20 ++-
 ...codeDecode.java => MqttPubackEncodeDecode.java} |  20 ++-
 ...odeDecode.java => MqttPublishEncodeDecode.java} |  34 ++--
 ...codeDecode.java => MqttSubackEncodeDecode.java} |  21 ++-
 ...eDecode.java => MqttSubscribeEncodeDecode.java} |  30 ++--
 ...deDecode.java => MqttUnSubackEncodeDecode.java} |  20 ++-
 ...ecode.java => MqttUnSubscribeEncodeDecode.java} |  30 ++--
 .../org/apache/rocketmq/snode/SnodeController.java |  50 ++----
 .../org/apache/rocketmq/snode/client/Client.java   |  58 +++++--
 .../snode/client/impl/IOTClientManagerImpl.java    |  53 +++++-
 .../rocketmq/snode/client/impl/Subscription.java   |   9 ++
 .../snode/exception/MqttConnectException.java      |   9 +-
 .../snode/exception/WrongMessageTypeException.java |   9 +-
 .../processor/DefaultMqttMessageProcessor.java     |  48 +++++-
 .../mqtthandler/MqttConnectMessageHandler.java     | 119 +++++++++++++-
 .../mqtthandler/MqttDisconnectMessageHandler.java  |  32 +++-
 .../mqtthandler/MqttSubscribeMessageHandler.java   | 129 +++++++++++++--
 ...{ClientService.java => WillMessageService.java} |  10 +-
 .../snode/service/impl/ClientServiceImpl.java      |   1 +
 .../impl/WillMessageServiceImpl.java}              |  28 ++--
 .../apache/rocketmq/snode/util/MessageUtil.java    | 178 ---------------------
 .../MqttUtil.java}                                 |  22 ++-
 .../processor/DefaultMqttMessageProcessorTest.java |   5 +-
 ....java => MqttDisconnectMessageHandlerTest.java} |  30 ++--
 .../snode/service/WillMessageServiceImplTest.java  |  57 +++++++
 .../rocketmq/store/DefaultMessageStoreTest.java    |   5 +-
 .../store/dledger/DLedgerCommitlogTest.java        |   4 -
 .../rocketmq/store/dledger/MixCommitlogTest.java   |   3 -
 41 files changed, 1102 insertions(+), 559 deletions(-)
 copy common/src/main/java/org/apache/rocketmq/common/{stats/StatsSnapshot.java => message/mqtt/RetainMessage.java} (63%)
 copy broker/src/main/java/org/apache/rocketmq/broker/transaction/OperationResult.java => common/src/main/java/org/apache/rocketmq/common/message/mqtt/WillMessage.java (52%)
 create mode 100644 common/src/main/java/org/apache/rocketmq/common/protocol/heartbeat/MqttSubscriptionData.java
 create mode 100644 remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/RocketMQMqttSubAckPayload.java
 create mode 100644 remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/RocketMQMqttSubscribePayload.java
 create mode 100644 remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/RocketMQMqttUnSubscribePayload.java
 copy remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/dispatcher/{MqttConnectackEncodeDecode.java => MqttPubackEncodeDecode.java} (52%)
 copy remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/dispatcher/{MqttConnectEncodeDecode.java => MqttPublishEncodeDecode.java} (62%)
 copy remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/dispatcher/{MqttConnectackEncodeDecode.java => MqttSubackEncodeDecode.java} (50%)
 copy remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/dispatcher/{MqttConnectEncodeDecode.java => MqttSubscribeEncodeDecode.java} (63%)
 copy remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/dispatcher/{MqttConnectackEncodeDecode.java => MqttUnSubackEncodeDecode.java} (51%)
 copy remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/dispatcher/{MqttConnectEncodeDecode.java => MqttUnSubscribeEncodeDecode.java} (62%)
 copy common/src/main/java/org/apache/rocketmq/common/filter/impl/Operand.java => snode/src/main/java/org/apache/rocketmq/snode/exception/MqttConnectException.java (81%)
 copy common/src/main/java/org/apache/rocketmq/common/filter/impl/Operand.java => snode/src/main/java/org/apache/rocketmq/snode/exception/WrongMessageTypeException.java (81%)
 copy snode/src/main/java/org/apache/rocketmq/snode/service/{ClientService.java => WillMessageService.java} (76%)
 copy snode/src/main/java/org/apache/rocketmq/snode/{client/impl/IOTClientManagerImpl.java => service/impl/WillMessageServiceImpl.java} (57%)
 delete mode 100644 snode/src/main/java/org/apache/rocketmq/snode/util/MessageUtil.java
 copy snode/src/main/java/org/apache/rocketmq/snode/{client/impl/ProducerManagerImpl.java => util/MqttUtil.java} (64%)
 copy snode/src/test/java/org/apache/rocketmq/snode/processor/{MqttConnectMessageHandlerTest.java => MqttDisconnectMessageHandlerTest.java} (56%)
 create mode 100644 snode/src/test/java/org/apache/rocketmq/snode/service/WillMessageServiceImplTest.java