-
Notifications
You must be signed in to change notification settings - Fork 12k
[RIP-83] Lite Topic: A New Message Model #9800
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
base: develop
Are you sure you want to change the base?
Conversation
e7deabc to
17bc455
Compare
broker/src/main/java/org/apache/rocketmq/broker/lite/AbstractLiteLifecycleManager.java
Show resolved
Hide resolved
broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java
Outdated
Show resolved
Hide resolved
broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java
Outdated
Show resolved
Hide resolved
broker/src/main/java/org/apache/rocketmq/broker/lite/AbstractLiteLifecycleManager.java
Show resolved
Hide resolved
fb2a03f to
537fee9
Compare
Codecov Report❌ Patch coverage is Additional details and impacted files@@ Coverage Diff @@
## develop #9800 +/- ##
=============================================
- Coverage 48.91% 48.64% -0.27%
- Complexity 12770 13188 +418
=============================================
Files 1324 1370 +46
Lines 96288 99431 +3143
Branches 12409 12835 +426
=============================================
+ Hits 47097 48366 +1269
- Misses 43458 45189 +1731
- Partials 5733 5876 +143 ☔ View full report in Codecov by Sentry. 🚀 New features to boost your workflow:
|
2d9967b to
5e8d18a
Compare
3724400 to
065b58e
Compare
Change-Id: Ie83f5ad363eb7b7c48371a0f4b3eab9f04465b81
Change-Id: I102d2bf7b5d573f41416333135074cde1a9f1fec
065b58e to
d66a9e2
Compare
Change-Id: Iadc1e2c74f1a05954c4015faa92cefb5786cdc0f
d66a9e2 to
365d605
Compare
Change-Id: I360bfb5d2ee12d2f5cc7a72343872c12c1bc5bd5
fbef7e3 to
8688da8
Compare
Change-Id: If8174ba1e35c899e8fa9067923fea7ecb69291e1
8688da8 to
2c1940d
Compare
|
|
||
| public static final int POP_LITE_MESSAGE = 200070; | ||
| public static final int LITE_SUBSCRIPTION_CTL = 200071; | ||
| public static final int ACK_LITE_MESSAGE = 200072; |
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.
ACK_LITE_MESSAGE is not used

Which Issue(s) This PR Fixes
Fixes #9797
Brief Description
RIP‐83 Lite Topic: A New Message Model
https://github.com/apache/rocketmq/wiki/RIP%E2%80%9083-Lite-Topic:-A-New-Message-Model
How Did You Test This Change?