You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2022/10/14 07:35:06 UTC
[rocketmq] branch develop updated (2bb562cd9 -> ffb17cad3)
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from 2bb562cd9 Add preShutdown for StartAndShutdown (#5194)
add ffb17cad3 [ISSUE 3799] add compaction delete policy (#5260)
No new revisions were added by this update.
Summary of changes:
.../broker/processor/SendMessageProcessor.java | 14 ++++++
.../apache/rocketmq/common/TopicAttributes.java | 16 +++++--
.../rocketmq/common/attribute/CleanupPolicy.java | 8 ++--
.../rocketmq/common/utils/DeletePolicyUtils.java | 50 ++++++++++++++++++++++
4 files changed, 80 insertions(+), 8 deletions(-)
copy test/src/main/java/org/apache/rocketmq/test/util/data/collect/DataFilter.java => common/src/main/java/org/apache/rocketmq/common/attribute/CleanupPolicy.java (88%)
create mode 100644 common/src/main/java/org/apache/rocketmq/common/utils/DeletePolicyUtils.java