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 af04be9 Merge pull request #156 from DongyuanPan/develop_fix_unit_test
new 5a0af74 Retained message based on raft state machine
new 90bdd0e Merge branch 'develop' into develop
new 25eeb5e fix some problems
new 7025ae2 Merge branch 'apache:develop' into develop
new 5ce4c74 Fix some problems
new 0c0fdc3 Add the license
new 6939c0d Change store retained msg type
new 021d0d5 Fix some problems about log
new 0a6885d Format the code
new 1844bf1 Format the code and add unit test
new 249d066 Format the code and add unit test
new eba9c5b Format the code and add unit test
new 66e8e9d fix ci
new d1c51cf fix ci
new 8508df4 fix ci
new f67d474 Merge branch 'develop' into develop
new 641e174 Merge remote-tracking branch 'origin/develop' into develop
new 20d0c0e Encoding message by protobuf
new ee03f36 Simplify protobuf file
new 4d0e593 Fix the code style
new cfcb67b Fix the problem
new 84cf866 Merge branch 'develop' into develop
new 881a6b6 Merge the conflict
new 6f8dd41 Fix the CI
new ca54807 Merge branch 'develop' into develop
new 748c841 Merge pull request #131 from YYYYWD/develop
The 191 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:
conf/meta.conf | 3 +-
conf/service.conf | 2 +
conf/spring.xml | 2 +-
.../apache/rocketmq/mqtt/meta/config/MetaConf.java | 13 +-
.../rocketmq/mqtt/meta/raft/MqttRaftServer.java | 5 +
.../rocketmq/mqtt/meta/raft/MqttStateMachine.java | 9 +-
.../mqtt/meta/raft/processor/Constants.java | 2 +
.../meta/raft/processor/CounterStateProcessor.java | 28 +-
.../raft/processor/RetainedMsgStateProcessor.java | 188 ++++++++++++++
.../mqtt/meta/raft/processor/StateProcessor.java | 6 +
.../mqtt/meta/raft/RetainedMsgClientTest.java | 283 +++++++++++++++++++++
mqtt-common/pom.xml | 4 +
...istManager.java => RetainedPersistManager.java} | 36 +--
.../mqtt/common/hook/AbstractUpstreamHook.java | 4 +-
.../rocketmq/mqtt/common/model/Constants.java | 2 +
.../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/util/MessageUtil.java | 28 +-
.../rocketmq/mqtt/common/util/TopicUtils.java | 12 +-
mqtt-common/src/main/proto/request.proto | 16 ++
.../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 ++-
.../protocol/mqtt/handler/MqttPubRecHandler.java | 2 +
.../mqtt/handler/MqttSubscribeHandler.java | 66 ++++-
.../cs/protocol/ws/WebSocketServerHandler.java | 10 +-
.../rocketmq/mqtt/cs/session/infly/PushAction.java | 36 ++-
.../mqtt/handler/TestMqttSubscribeHandler.java | 8 +-
.../mqtt/cs/test/session/infly/TestPushAction.java | 6 +
mqtt-ds/pom.xml | 10 +
.../rocketmq/mqtt/ds/config/ServiceConf.java | 13 +
.../mqtt/ds/meta/RetainedPersistManagerImpl.java | 99 +++++++
.../rocketmq/mqtt/ds/retain/RetainedMsgClient.java | 224 ++++++++++++++++
.../mqtt/ds/store/LmqQueueStoreManager.java | 2 +
.../mqtt/ds/upstream/UpstreamProcessor.java | 4 +-
.../mqtt/ds/upstream/UpstreamProcessorManager.java | 1 +
.../ds/upstream/processor/PublishProcessor.java | 45 +++-
.../upstream/TestUpstreamProcessorManager.java | 5 +-
.../upstream/processor/TestPublishProcessor.java | 3 +-
.../mqtt/exporter/http/BackedFileOutputStream.java | 2 +-
pom.xml | 7 +-
45 files changed, 1446 insertions(+), 124 deletions(-)
create mode 100644
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcessor.java
create mode 100644
meta/src/test/java/org/apache/rocketmq/mqtt/meta/raft/RetainedMsgClientTest.java
copy
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/{MetaPersistManager.java
=> RetainedPersistManager.java} (64%)
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/retain/RetainedMsgClient.java
