This is an automated email from the ASF dual-hosted git repository.
pingww pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
from be7fc89 add entire project overview link
add fa2d920 fix prometheus log error when set prometheus to false
add c50ae5b Merge pull request #183 from DongyuanPan/fix_prometheus
add 21a4149 hash kv
add 426c162 meta
add 3966975 meta
add 4563caf meta
add c1c715d hash kv
add 1c7618e hash kv
add c278cb7 hash kv
add 7f62031 hash kv
add b263e03 hash kv
add 4058b8e meta
add 5fc0364 meta
add f662185 meta
add de281a1 will
add a51a0b3 will
add 1b82929 will
add 222a541 will
add 76fb743 Apply Listener
add 24f726a Apply Listener
add 9493825 will
add 1a3cef6 will, retain
add abd80fb meta
add db6ce02 retain
add d2428ce retain
add 5ea1339 will
add 4e5503b scan num
add f572bab stat
add 0d0d087 log
add de8ef54 fix
add 515861f Merge pull request #188 from pingww/develop
add 5ae61f6 fixNullPointInWill: should config meta addr in cs
add 2c8289e Merge pull request #199 from DongyuanPan/fixNullPointInWill
add 1d0b869 [ISSUE #44] Support shared subscription
add e69841d Merge pull request #194 from
ferrirW/support-shared-subscription-model-dev
add 40369cd fix bug: Compilation failed with rocketmq 4.9.4 and adapt to
rocketmq 5.1.3
add a1397d0 fix log
add 736b7b2 Merge pull request #204 from DongyuanPan/develop_rmq-5.1.3
new 7b556f9 Merge pull request #218 from apache/develop
The 1 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 | 16 +-
distribution/bin/meta.sh | 2 +-
mqtt-common/pom.xml | 4 +
.../rocketmq/mqtt/common/facade/LmqQueueStore.java | 13 ++
.../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 +
.../rocketmq/mqtt/common/model/Constants.java | 3 +
.../rocketmq/mqtt/common/model/PullResult.java | 1 +
.../apache/rocketmq/mqtt/common/model/Queue.java | 4 +
.../rocketmq/mqtt/common/model/Subscription.java | 11 ++
.../rocketmq/mqtt/common/util/TopicUtils.java | 23 +++
mqtt-cs/pom.xml | 4 +
.../mqtt/cs/channel/DefaultChannelManager.java | 87 +---------
.../rocketmq/mqtt/cs/config/WillLoopConf.java | 57 +++++++
.../protocol/mqtt/handler/MqttConnectHandler.java | 6 +-
.../mqtt/handler/MqttSubscribeHandler.java | 5 +-
.../apache/rocketmq/mqtt/cs/session/Session.java | 3 +
.../rocketmq/mqtt/cs/session/infly/PushAction.java | 7 +
.../rocketmq/mqtt/cs/session/loop/QueueCache.java | 9 +-
.../rocketmq/mqtt/cs/session/loop/SessionLoop.java | 2 -
.../mqtt/cs/session/loop/SessionLoopImpl.java | 32 +---
.../rocketmq/mqtt/cs/session/loop/WillLoop.java | 169 ++++++++++++------
.../apache/rocketmq/mqtt/cs/starter/Startup.java | 4 +-
.../rocketmq/mqtt/ds/config/ServiceConf.java | 12 +-
.../rocketmq/mqtt/ds/meta/FirstTopicManager.java | 8 +-
.../mqtt/ds/meta/MetaPersistManagerSample.java | 2 +-
.../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 +-
.../rocketmq/mqtt/ds/notify/NotifyManager.java | 2 +
.../mqtt/ds/store/LmqOffsetStoreManager.java | 6 +-
.../mqtt/ds/store/LmqQueueStoreManager.java | 189 ++++++++++++++++++++-
.../ds/upstream/processor/PublishProcessor.java | 21 ++-
.../mqtt/ds/test/meta/TestFirstTopicManager.java | 8 +-
.../test/meta/WillMsgPersistManagerImplTest.java | 2 +-
.../ds/test/store/TestLmqQueueStoreManager.java | 3 +-
mqtt-exporter/pom.xml | 4 +
.../exporter/collector/MqttMetricsCollector.java | 4 +
.../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 +
.../starter/{Startup.java => MetaStartup.java} | 10 +-
.../mqtt/meta/raft/RetainedMsgClientTest.java | 8 +-
.../mqtt/meta/raft/WillMsgStateProcessorTest.java | 4 +-
pom.xml | 8 +-
59 files changed, 1136 insertions(+), 405 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
rename
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/starter/{Startup.java =>
MetaStartup.java} (85%)
