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 c50ae5b Merge pull request #183 from DongyuanPan/fix_prometheus
new 21a4149 hash kv
new 426c162 meta
new 3966975 meta
new 4563caf meta
new c1c715d hash kv
new 1c7618e hash kv
new c278cb7 hash kv
new 7f62031 hash kv
new b263e03 hash kv
new 4058b8e meta
new 5fc0364 meta
new f662185 meta
new de281a1 will
new a51a0b3 will
new 1b82929 will
new 222a541 will
new 76fb743 Apply Listener
new 24f726a Apply Listener
new 9493825 will
new 1a3cef6 will, retain
new abd80fb meta
new db6ce02 retain
new d2428ce retain
new 5ea1339 will
new 4e5503b scan num
new f572bab stat
new 0d0d087 log
new de8ef54 fix
new 515861f Merge pull request #188 from pingww/develop
The 314 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:
.../mqtt/common/facade/RetainedPersistManager.java | 3 +-
.../mqtt/common/facade/WillMsgPersistManager.java | 3 +-
.../Constants.java => facade/WillMsgSender.java} | 13 +-
.../rocketmq/mqtt/common/meta/MetaConstants.java | 62 +++++++
.../apache/rocketmq/mqtt/common/meta/RaftUtil.java | 1 +
.../mqtt/cs/channel/DefaultChannelManager.java | 87 +---------
.../rocketmq/mqtt/cs/config/WillLoopConf.java | 57 +++++++
.../protocol/mqtt/handler/MqttConnectHandler.java | 6 +-
.../mqtt/handler/MqttSubscribeHandler.java | 5 +-
.../rocketmq/mqtt/cs/session/loop/SessionLoop.java | 2 -
.../mqtt/cs/session/loop/SessionLoopImpl.java | 30 ----
.../rocketmq/mqtt/cs/session/loop/WillLoop.java | 169 ++++++++++++------
.../rocketmq/mqtt/ds/config/ServiceConf.java | 12 +-
.../rocketmq/mqtt/ds/meta/MetaRpcClient.java | 7 +-
.../rocketmq/mqtt/ds/meta/RetainedMsgClient.java | 70 ++++++--
.../mqtt/ds/meta/RetainedPersistManagerImpl.java | 11 +-
.../rocketmq/mqtt/ds/meta/WillMsgClient.java | 32 ++--
.../mqtt/ds/meta/WillMsgPersistManagerImpl.java | 4 +-
.../ds/upstream/processor/PublishProcessor.java | 21 ++-
.../test/meta/WillMsgPersistManagerImplTest.java | 2 +-
.../apache/rocketmq/mqtt/meta/config/MetaConf.java | 69 ++++----
.../mqtt/meta/config/MetaConfListener.java | 3 +
...FailoverClosure.java => MqttApplyListener.java} | 17 +-
.../rocketmq/mqtt/meta/raft/MqttRaftServer.java | 49 +++++-
.../rocketmq/mqtt/meta/raft/MqttStateMachine.java | 85 +++++-----
.../meta/raft/processor/HashKvStateProcessor.java | 188 +++++++++++++++++++++
.../raft/processor/RetainedMsgStateProcessor.java | 75 +++++---
.../mqtt/meta/raft/processor/StateProcessor.java | 9 +-
.../meta/raft/processor/WillMsgStateProcessor.java | 52 ++++--
.../mqtt/meta/raft/rpc/AbstractRpcProcessor.java | 2 +-
.../mqtt/meta/raft/rpc/MqttReadRpcProcessor.java | 31 +++-
.../mqtt/meta/raft/rpc/MqttWriteRpcProcessor.java | 2 +
.../mqtt/meta/raft/RetainedMsgClientTest.java | 8 +-
.../mqtt/meta/raft/WillMsgStateProcessorTest.java | 4 +-
pom.xml | 1 +
35 files changed, 821 insertions(+), 371 deletions(-)
rename
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/{meta/Constants.java
=> facade/WillMsgSender.java} (70%)
create mode 100644
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/meta/MetaConstants.java
create mode 100644
mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/WillLoopConf.java
copy
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/{FailoverClosure.java
=> MqttApplyListener.java} (74%)
create mode 100644
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/HashKvStateProcessor.java
