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 e31fbf1 Merge pull request #177 from pingww/develop
new e0dc5a8 Refactor：will, retain
new c78a3b5 will, retain
new d9af15c will, retain
new fe3af2d will, retain
new 9dd0cf8 will, retain
new 0210408 will, retain
new 4967a21 Merge pull request #178 from pingww/develop
The 280 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:
README.md | 3 +-
distribution/conf/connect.conf | 1 +
distribution/conf/meta.conf | 1 -
.../mqtt/cs/session/loop/SessionLoopImpl.java | 184 ----------------
.../rocketmq/mqtt/cs/session/loop/WillLoop.java | 238 +++++++++++++++++++++
.../rocketmq/mqtt/ds/meta/MetaRpcClient.java | 2 +-
.../mqtt/example/MqttWillRetainConsumer.java | 2 +-
.../mqtt/example/MqttWillRetainProducer.java | 35 +--
.../apache/rocketmq/mqtt/meta/config/MetaConf.java | 12 +-
.../rocketmq/mqtt/meta/raft/MqttRaftServer.java | 28 ++-
.../rocketmq/mqtt/meta/raft/MqttStateMachine.java | 8 +-
.../raft/processor/RetainedMsgStateProcessor.java | 47 ++--
.../mqtt/meta/raft/processor/StateProcessor.java | 76 ++++++-
.../meta/raft/processor/WillMsgStateProcessor.java | 68 +-----
.../mqtt/meta/rocksdb/RocksDBSnapshot.java | 10 +-
.../rocketmq/mqtt/meta/util/RaftExecutor.java | 45 ----
16 files changed, 399 insertions(+), 361 deletions(-)
create mode 100644
mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/WillLoop.java
delete mode 100644
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/util/RaftExecutor.java
