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 eadd10c Merge pull request #176 from pingww/main
add 316c30e fix bug dependency
add 0660867 add counter example in raft module
add 390a286 manager multi raft group
add c0d5df3 change store log for raft: each group a raft uri
add 6494a2e init commit for jraft with grpc
add dcb27ce delete kv
add 2a37ed2 delete blot rpc
add 75c043b fix ci
add afd1302 Merge pull request #122 from DongyuanPan/raft_state_machine
add 5088187 add snapshot to raft state machine
add dca7dce simplify codes
add dd822bc fix bug and simplify codes
add 6a1ec83 add snapshot to raft state machine
add ed56ff4 bug fix
add ee3c4f6 Merge pull request #127 from scutcr7/develop
add 5a0af74 Retained message based on raft state machine
add 4fac7e8 add some comment (#128)
add af50ca0 Unified Group ID separator (#129)
add 90bdd0e Merge branch 'develop' into develop
add 25eeb5e fix some problems
add 861ecf2 bug fix: change groupid
add c8f6b55 Merge pull request #134 from DongyuanPan/develop_groupID
add 7025ae2 Merge branch 'apache:develop' into develop
add 5ce4c74 Fix some problems
add 0c0fdc3 Add the license
add 6939c0d Change store retained msg type
add 021d0d5 Fix some problems about log
add 0a6885d Format the code
add 1844bf1 Format the code and add unit test
add 249d066 Format the code and add unit test
add eba9c5b Format the code and add unit test
add 66e8e9d fix ci
add d1c51cf fix ci
add 8508df4 fix ci
add 4a8ea1b delete unused data member
add 9e58e01 delete SnapshotOperation in abstract abstract class
StateProcessor
add dee34c9 delete SnapshotOperation in abstract abstract class
StateProcessor. fix code style
add 9b1f8d1 Merge pull request #136 from DongyuanPan/snapshot
add f67d474 Merge branch 'develop' into develop
add 641e174 Merge remote-tracking branch 'origin/develop' into develop
add 20d0c0e Encoding message by protobuf
add ee03f36 Simplify protobuf file
add 4d0e593 Fix the code style
add cfcb67b Fix the problem
add bad331a Update readme (#148)
add 79d664f update readme
add 5be9909 add LMQ prefix
add 41b6e8b Merge pull request #151 from
DongyuanPan/develop_add_lmq_prefix
add e67c9bd fix code style
add fe85a5e add MqttMessageFactory and optimize codes.
add 493327c add license and import specific classes.
add 12e22a5 Fix CI error.
add e754f3d Merge pull request #138 from wangzhiwei1314/develop
add 84cf866 Merge branch 'develop' into develop
add 881a6b6 Merge the conflict
add 6f8dd41 Fix the CI
add af1cdf9 fix unit test
add af04be9 Merge pull request #156 from DongyuanPan/develop_fix_unit_test
add ca54807 Merge branch 'develop' into develop
add 748c841 Merge pull request #131 from YYYYWD/develop
add 3f8db8b merge main
add 01fb72b merge main: fix conflict
add eccebec Merge pull request #158 from DongyuanPan/develop_merge_main
add 0a4c230 Move rpc code out of state machine processor
add 4f5dae9 Merge pull request #168 from DongyuanPan/develop_refactor
add 3a79140 [ISSUE #163]Optimize format (#164)
add c9fa708 implement will message
add 2fa29af use MQ to dispatch remote clients
add b46ca67 Merge remote-tracking branch 'upstream/main' into KV add KV
add 66b5a35 test will message with kv
add 2ec6296 implement will message with kv
add 4eca347 add schedule task
add 8e3fe54 send messages when the server is down using scheduled tasks
add 1e1e816 send will message in ds and fix travis CI bug
add 4694fbe normalize codes
add 0d6c0f8 Merge branch 'develop' into final
add c9d4aa1 add will state processor
add d116403 add will state processor, fix code style
add 45d3b22 add will state processor, fix code style
add 74a8f5e add example
add 00ab034 bugfix Class WillMessage
add 8bf300d wait cs up and then handle will msg
add 83a6837 add snapshot for will
add 776e5b3 init commit for will message
add 6bcd155 fix unit test
add 9a7915d create will processor db dir
add 96be253 add will state processor, fix code style
add 0ced295 add will state processor, fix code style
add 77d9a30 add will state processor, fix code style
add c5c8189 debug
add 3e935ff debug
add baaf949 debug
add 61fa5f4 debug
add b40976f add example
add e12d097 add example
add 16e5921 add example
add 530ab64 bugfix Class WillMessage
add 5c9e8e9 wait cs up and then handle will msg
add 81c8fc6 add snapshot for will
add e673f0b init commit for will message
add ec5969f init commit for will message
add 2a0cbd5 fix unit test
add d568404 fix unit test
add a16db9a [RIP-60] Support Will Message In RocketMQ-MQTT
add 4d85f26 Merge pull request #174 from DongyuanPan/develop_will
add fd6c137 Fix the error about empty retained message
add f7cad0e Merge pull request #175 from YYYYWD/develop
add d348e95 Merge branch 'main' into develop
add b5b89a4 fix
add fbefc84 fix
add 6d0ce6d will, retain
add d8fbb31 will, retain
add edbfa39 Refactor：will, retain
add e31fbf1 Merge pull request #177 from pingww/develop
add e0dc5a8 Refactor：will, retain
add c78a3b5 will, retain
add d9af15c will, retain
add fe3af2d will, retain
add 9dd0cf8 will, retain
add 0210408 will, retain
add 4967a21 Merge pull request #178 from pingww/develop
add 9eefd09 [maven-release-plugin] prepare release rocketmq-mqtt-1.0.1
add 555b467 [maven-release-plugin] prepare for next development iteration
add 6454eb6 1.0.1
add 501ade3 Merge pull request #179 from apache/develop
No new revisions were added by this update.
Summary of changes:
README.md | 24 +-
distribution/bin/{mqtt.sh => meta.sh} | 5 +-
distribution/conf/connect.conf | 1 +
distribution/conf/{connect.conf => meta.conf} | 4 +-
distribution/conf/{spring.xml => meta_spring.xml} | 12 +-
distribution/conf/service.conf | 2 +
distribution/conf/spring.xml | 3 +-
distribution/pom.xml | 2 +-
distribution/release.xml | 1 +
mqtt-common/pom.xml | 50 +++-
...istManager.java => RetainedPersistManager.java} | 36 +--
.../common/facade/SubscriptionPersistManager.java | 24 ++
...sistManager.java => WillMsgPersistManager.java} | 27 +-
.../mqtt/common/hook/AbstractUpstreamHook.java | 4 +-
.../{model/TrieMethod.java => meta/Constants.java} | 15 +-
.../apache/rocketmq/mqtt/common/meta/IpUtil.java | 114 +++++++++
.../apache/rocketmq/mqtt/common/meta/RaftUtil.java | 50 ++++
.../rocketmq/mqtt/common/model/Constants.java | 15 ++
.../apache/rocketmq/mqtt/common/model/Message.java | 63 ++++-
.../rocketmq/mqtt/common/model/Subscription.java | 12 +-
.../apache/rocketmq/mqtt/common/model/Trie.java | 118 ++++++++-
.../rocketmq/mqtt/common/model/WillMessage.java | 80 ++++++
.../rocketmq/mqtt/common/util/MessageUtil.java | 28 +-
.../rocketmq/mqtt/common/util/TopicUtils.java | 12 +-
mqtt-common/src/main/proto/request.proto | 64 +++++
.../common/test/hook/TestAbstractUpstreamHook.java | 29 +--
.../mqtt/common/test/hook/TestHookResult.java | 26 +-
.../mqtt/common/test/model/TestMessage.java | 30 ++-
.../rocketmq/mqtt/common/test/model/TestTrie.java | 63 ++++-
.../mqtt/common/test/util/TestHostInfo.java | 4 +-
.../mqtt/common/test/util/TestMessageUtil.java | 39 ++-
mqtt-cs/pom.xml | 6 +-
.../mqtt/cs/channel/DefaultChannelManager.java | 89 +++++++
.../rocketmq/mqtt/cs/config/ConnectConf.java | 10 +-
.../protocol/mqtt/facotry/MqttMessageFactory.java | 105 ++++++++
.../protocol/mqtt/handler/MqttConnectHandler.java | 44 ++--
.../cs/protocol/mqtt/handler/MqttPingHandler.java | 9 +-
.../protocol/mqtt/handler/MqttPubRecHandler.java | 1 +
.../protocol/mqtt/handler/MqttPubRelHandler.java | 9 +-
.../protocol/mqtt/handler/MqttPublishHandler.java | 20 +-
.../mqtt/handler/MqttSubscribeHandler.java | 84 +++++-
.../mqtt/handler/MqttUnSubscribeHandler.java | 18 +-
.../cs/protocol/ws/WebSocketServerHandler.java | 10 +-
.../apache/rocketmq/mqtt/cs/session/Session.java | 11 +
.../rocketmq/mqtt/cs/session/infly/PushAction.java | 38 ++-
.../rocketmq/mqtt/cs/session/loop/SessionLoop.java | 2 +
.../mqtt/cs/session/loop/SessionLoopImpl.java | 43 ++++
.../rocketmq/mqtt/cs/session/loop/WillLoop.java | 238 +++++++++++++++++
.../rocketmq/mqtt/cs/starter/MqttServer.java | 8 +-
.../cs/test/channel/TestDefaultChannelManager.java | 125 +++++----
.../mqtt/handler/TestMqttSubscribeHandler.java | 8 +-
.../mqtt/cs/test/session/infly/TestPushAction.java | 6 +
mqtt-ds/pom.xml | 10 +-
.../rocketmq/mqtt/ds/config/ServiceConf.java | 57 +----
.../rocketmq/mqtt/ds/meta/MetaRpcClient.java | 118 +++++++++
.../rocketmq/mqtt/ds/meta/RetainedMsgClient.java | 201 +++++++++++++++
.../mqtt/ds/meta/RetainedPersistManagerImpl.java | 101 ++++++++
.../rocketmq/mqtt/ds/meta/WillMsgClient.java | 185 ++++++++++++++
.../mqtt/ds/meta/WillMsgPersistManagerImpl.java | 108 ++++++++
.../mqtt/ds/store/LmqOffsetStoreManager.java | 4 +-
.../mqtt/ds/store/LmqQueueStoreManager.java | 2 +
.../mqtt/ds/upstream/UpstreamProcessor.java | 4 +-
.../mqtt/ds/upstream/UpstreamProcessorManager.java | 1 +
.../ds/upstream/processor/PublishProcessor.java | 45 +++-
.../test/meta/WillMsgPersistManagerImplTest.java | 129 ++++++++++
.../upstream/TestUpstreamProcessorManager.java | 5 +-
.../upstream/processor/TestPublishProcessor.java | 3 +-
mqtt-example/pom.xml | 2 +-
.../apache/rocketmq/mqtt/example/MqttConsumer.java | 11 +-
.../apache/rocketmq/mqtt/example/MqttProducer.java | 9 +-
...ttConsumer.java => MqttWillRetainConsumer.java} | 21 +-
...ttProducer.java => MqttWillRetainProducer.java} | 59 ++---
.../rocketmq/mqtt/example/RocketMQConsumer.java | 2 +-
.../rocketmq/mqtt/example/RocketMQProducer.java | 2 +-
mqtt-exporter/pom.xml | 2 +-
mqtt-meta/pom.xml | 55 ++++
.../apache/rocketmq/mqtt/meta/config/MetaConf.java | 146 +++++++++++
.../mqtt/meta/config/MetaConfListener.java | 29 +--
.../rocketmq/mqtt/meta/raft/FailoverClosure.java | 16 +-
.../rocketmq/mqtt/meta/raft/MqttClosure.java | 154 +++++++++++
.../rocketmq/mqtt/meta/raft/MqttRaftServer.java | 276 ++++++++++++++++++++
.../rocketmq/mqtt/meta/raft/MqttStateMachine.java | 147 +++++++++++
.../raft/processor/RetainedMsgStateProcessor.java | 181 +++++++++++++
.../mqtt/meta/raft/processor/StateProcessor.java | 187 ++++++++++++++
.../meta/raft/processor/WillMsgStateProcessor.java | 103 ++++++++
.../mqtt/meta/raft/rpc/AbstractRpcProcessor.java | 172 +++++++++++++
.../mqtt/meta/raft/rpc/MqttReadRpcProcessor.java | 49 ++++
.../mqtt/meta/raft/rpc/MqttWriteRpcProcessor.java | 32 ++-
.../rocketmq/mqtt/meta/rocksdb/RocksDBEngine.java | 124 +++++++++
.../mqtt/meta/rocksdb/RocksDBSnapshot.java | 160 ++++++++++++
.../apache/rocketmq/mqtt/meta/starter/Startup.java | 31 +++
.../apache/rocketmq/mqtt/meta/util/DiskUtils.java | 146 +++++++++++
.../apache/rocketmq/mqtt/meta/util/SpringUtil.java | 32 ++-
.../mqtt/meta/raft/RetainedMsgClientTest.java | 283 +++++++++++++++++++++
.../mqtt/meta/raft/WillMsgStateProcessorTest.java | 136 ++++++++++
.../apache/rocketmq/mqtt/meta/util/IpUtilTest.java | 60 +++++
pom.xml | 85 ++++++-
97 files changed, 5061 insertions(+), 465 deletions(-)
copy distribution/bin/{mqtt.sh => meta.sh} (97%)
copy distribution/conf/{connect.conf => meta.conf} (96%)
copy distribution/conf/{spring.xml => meta_spring.xml} (84%)
copy
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/{MetaPersistManager.java
=> RetainedPersistManager.java} (64%)
copy
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/{MetaPersistManager.java
=> WillMsgPersistManager.java} (62%)
copy
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/{model/TrieMethod.java
=> meta/Constants.java} (71%)
create mode 100644
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/meta/IpUtil.java
create mode 100644
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/meta/RaftUtil.java
create mode 100644
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/WillMessage.java
create mode 100644 mqtt-common/src/main/proto/request.proto
create mode 100644
mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/facotry/MqttMessageFactory.java
create mode 100644
mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/WillLoop.java
create mode 100644
mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/MetaRpcClient.java
create mode 100644
mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedMsgClient.java
create mode 100644
mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedPersistManagerImpl.java
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
=> MqttWillRetainConsumer.java} (88%)
copy
mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/{MqttProducer.java
=> MqttWillRetainProducer.java} (68%)
create mode 100644 mqtt-meta/pom.xml
create mode 100644
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/config/MetaConf.java
copy
mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConfListener.java
=>
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/config/MetaConfListener.java
(88%)
copy
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/TrieMethod.java
=>
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/FailoverClosure.java
(73%)
create mode 100644
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttClosure.java
create mode 100644
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttRaftServer.java
create mode 100644
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttStateMachine.java
create mode 100644
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcessor.java
create mode 100644
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/StateProcessor.java
create mode 100644
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/WillMsgStateProcessor.java
create mode 100644
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/rpc/AbstractRpcProcessor.java
create mode 100644
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/rpc/MqttReadRpcProcessor.java
copy
mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector/SubSystem.java
=>
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/rpc/MqttWriteRpcProcessor.java
(51%)
create mode 100644
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/rocksdb/RocksDBEngine.java
create mode 100644
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/rocksdb/RocksDBSnapshot.java
create mode 100644
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/starter/Startup.java
create mode 100644
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/util/DiskUtils.java
copy
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MqttTopic.java
=> mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/util/SpringUtil.java
(55%)
create mode 100644
mqtt-meta/src/test/java/org/apache/rocketmq/mqtt/meta/raft/RetainedMsgClientTest.java
create mode 100644
mqtt-meta/src/test/java/org/apache/rocketmq/mqtt/meta/raft/WillMsgStateProcessorTest.java
create mode 100644
mqtt-meta/src/test/java/org/apache/rocketmq/mqtt/meta/util/IpUtilTest.java
