-
Notifications
You must be signed in to change notification settings - Fork 67
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[ISSUE #70] Retained message based on raft state machine #131
Conversation
mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/UpstreamProcessorManager.java
Outdated
Show resolved
Hide resolved
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook/AbstractUpstreamHook.java
Outdated
Show resolved
Hide resolved
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Constants.java
Outdated
Show resolved
Hide resolved
meta/src/test/java/org/apache/rocketmq/mqtt/meta/raft/RetainedMsgClient.java
Outdated
Show resolved
Hide resolved
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/MessageUtil.java
Outdated
Show resolved
Hide resolved
link #118 |
the GID separator has been changed from "=" to "%", |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
the GID separator has been changed from "=" to "%",
rebase the latest develop branch and merge the PR #129 .
Using % can cause unpredictable errors, so use "-" instead |
@YYYYWD Y Using % can cause unpredictable errors, so use "-" instead. it can make a new pr to develop |
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/Constants.java
Outdated
Show resolved
Hide resolved
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcess.java
Outdated
Show resolved
Hide resolved
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcess.java
Outdated
Show resolved
Hide resolved
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcess.java
Outdated
Show resolved
Hide resolved
Does the state machine need to care about message content? Or use byte array storage directly, reducing serialization and deserialization. Trie tree retainedMsgTopicTrie in state machine also has the same problem |
To facilitate troubleshooting, you need to add error logs |
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcess.java
Outdated
Show resolved
Hide resolved
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcess.java
Outdated
Show resolved
Hide resolved
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcess.java
Outdated
Show resolved
Hide resolved
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcess.java
Outdated
Show resolved
Hide resolved
mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedPersistManagerImpl.java
Show resolved
Hide resolved
Codecov Report
@@ Coverage Diff @@
## develop #131 +/- ##
===========================================
- Coverage 41.96% 40.02% -1.94%
===========================================
Files 119 122 +3
Lines 4904 5314 +410
Branches 714 764 +50
===========================================
+ Hits 2058 2127 +69
- Misses 2491 2824 +333
- Partials 355 363 +8
📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more |
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcess.java
Outdated
Show resolved
Hide resolved
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcess.java
Outdated
Show resolved
Hide resolved
mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor/PublishProcessor.java
Outdated
Show resolved
Hide resolved
mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedPersistManagerImpl.java
Show resolved
Hide resolved
mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedPersistManagerImpl.java
Outdated
Show resolved
Hide resolved
mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor/PublishProcessor.java
Outdated
Show resolved
Hide resolved
Please adjust the code style, remove extra blank lines, and add spaces around certain symbols |
meta/src/test/java/org/apache/rocketmq/mqtt/meta/raft/RetainedMsgClientTest.java
Outdated
Show resolved
Hide resolved
...cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttSubscribeHandler.java
Outdated
Show resolved
Hide resolved
mqtt-cs/src/test/java/org/apache/rocketmq/mqtt/cs/test/session/infly/TestPushAction.java
Outdated
Show resolved
Hide resolved
mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedPersistManagerImpl.java
Outdated
Show resolved
Hide resolved
mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/retain/RetainedMsgClient.java
Outdated
Show resolved
Hide resolved
...cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttSubscribeHandler.java
Outdated
Show resolved
Hide resolved
mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/retain/RetainedMsgClient.java
Outdated
Show resolved
Hide resolved
mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/retain/RetainedMsgClient.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
GOOD JOB
@ShannonDing @pingww it can be merged |
meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttRaftServer.java
Outdated
Show resolved
Hide resolved
to resolve conflicts |
No description provided.