This is an automated email from the ASF dual-hosted git repository.
pingww pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
from 3a79140 [ISSUE #163]Optimize format (#164)
new c9fa708 implement will message
new 2fa29af use MQ to dispatch remote clients
new b46ca67 Merge remote-tracking branch 'upstream/main' into KV add KV
new 66b5a35 test will message with kv
new 2ec6296 implement will message with kv
new 4eca347 add schedule task
new 8e3fe54 send messages when the server is down using scheduled tasks
new 1e1e816 send will message in ds and fix travis CI bug
new 4694fbe normalize codes
new 0d6c0f8 Merge branch 'develop' into final
new c9d4aa1 add will state processor
new d116403 add will state processor, fix code style
new 45d3b22 add will state processor, fix code style
new 74a8f5e add example
new 00ab034 bugfix Class WillMessage
new 8bf300d wait cs up and then handle will msg
new 83a6837 add snapshot for will
new 776e5b3 init commit for will message
new 6bcd155 fix unit test
new 9a7915d create will processor db dir
new 96be253 add will state processor, fix code style
new 0ced295 add will state processor, fix code style
new 77d9a30 add will state processor, fix code style
new c5c8189 debug
new 3e935ff debug
new baaf949 debug
new 61fa5f4 debug
new b40976f add example
new e12d097 add example
new 16e5921 add example
new 530ab64 bugfix Class WillMessage
new 5c9e8e9 wait cs up and then handle will msg
new 81c8fc6 add snapshot for will
new e673f0b init commit for will message
new ec5969f init commit for will message
new 2a0cbd5 fix unit test
new d568404 fix unit test
new a16db9a [RIP-60] Support Will Message In RocketMQ-MQTT
new 4d85f26 Merge pull request #174 from DongyuanPan/develop_will
The 260 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:
distribution/conf/spring.xml | 1 +
.../common/facade/SubscriptionPersistManager.java | 24 ++
...sistManager.java => WillMsgPersistManager.java} | 15 +-
.../rocketmq/mqtt/common/model/Constants.java | 13 +
.../rocketmq/mqtt/common/model/WillMessage.java | 80 +++++
mqtt-common/src/main/proto/request.proto | 1 +
mqtt-cs/pom.xml | 4 +
.../mqtt/cs/channel/DefaultChannelManager.java | 89 +++++
.../protocol/mqtt/handler/MqttConnectHandler.java | 25 +-
.../apache/rocketmq/mqtt/cs/session/Session.java | 11 +
.../rocketmq/mqtt/cs/session/loop/SessionLoop.java | 2 +
.../mqtt/cs/session/loop/SessionLoopImpl.java | 230 +++++++++++++
.../rocketmq/mqtt/cs/starter/MqttServer.java | 2 +-
.../cs/test/channel/TestDefaultChannelManager.java | 125 ++++----
.../rocketmq/mqtt/ds/meta/MetaRpcClient.java | 98 ++++++
.../ds/{retain => meta}/RetainedMsgClient.java | 2 +-
.../mqtt/ds/meta/RetainedPersistManagerImpl.java | 2 -
.../rocketmq/mqtt/ds/meta/WillMsgClient.java | 179 +++++++++++
.../mqtt/ds/meta/WillMsgPersistManagerImpl.java | 108 +++++++
.../test/meta/WillMsgPersistManagerImplTest.java | 137 ++++++++
.../apache/rocketmq/mqtt/example/MqttConsumer.java | 10 +-
.../apache/rocketmq/mqtt/example/MqttProducer.java | 10 +-
.../{MqttConsumer.java => MqttWillConsumer.java} | 19 +-
.../{MqttProducer.java => MqttWillProducer.java} | 30 +-
.../rocketmq/mqtt/example/RocketMQConsumer.java | 2 +-
.../rocketmq/mqtt/example/RocketMQProducer.java | 2 +-
.../apache/rocketmq/mqtt/meta/config/MetaConf.java | 4 +-
.../rocketmq/mqtt/meta/raft/MqttRaftServer.java | 6 +-
.../rocketmq/mqtt/meta/raft/MqttStateMachine.java | 6 +-
.../mqtt/meta/raft/processor/StateProcessor.java | 4 +-
.../meta/raft/processor/WillMsgStateProcessor.java | 357 +++++++++++++++++++++
.../rocketmq/mqtt/meta/raft/rpc/Constants.java | 3 +
.../org/apache/rocketmq/mqtt/meta/util/IpUtil.java | 38 ++-
.../mqtt/meta/raft/WillMsgStateProcessorTest.java | 117 +++++++
.../apache/rocketmq/mqtt/meta/util/IpUtilTest.java | 1 +
35 files changed, 1612 insertions(+), 145 deletions(-)
copy
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/{RetainedPersistManager.java
=> WillMsgPersistManager.java} (66%)
create mode 100644
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/WillMessage.java
create mode 100644
mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/MetaRpcClient.java
rename mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/{retain =>
meta}/RetainedMsgClient.java (99%)
create mode 100644
mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java
create mode 100644
mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgPersistManagerImpl.java
create mode 100644
mqtt-ds/src/test/java/org/apache/rocketmq/mqtt/ds/test/meta/WillMsgPersistManagerImplTest.java
copy
mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/{MqttConsumer.java
=> MqttWillConsumer.java} (89%)
copy
mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/{MqttProducer.java
=> MqttWillProducer.java} (79%)
create mode 100644
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/WillMsgStateProcessor.java
create mode 100644
mqtt-meta/src/test/java/org/apache/rocketmq/mqtt/meta/raft/WillMsgStateProcessorTest.java
