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
