opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-10-24 23:31:43 +08:00
Code Issues Packages Projects Releases Wiki Activity

cleanup policy

Browse Source
This commit is contained in:
ltamber
2022-10-17 10:02:17 +08:00
parent 2993d1fe74
commit da76a4820b
2 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/src/main/java/org/apache/rocketmq/common/TopicAttributes.java
+3 -3
View File
@@ -31,8 +31,8 @@ public class TopicAttributes {
newHashSet("BatchCQ", "SimpleCQ"),
"SimpleCQ"
);
public static final EnumAttribute DELETE_POLICY_ATTRIBUTE = new EnumAttribute(
"delete.policy",
public static final EnumAttribute CLEANUP_POLICY_ATTRIBUTE = new EnumAttribute(
"cleanup.policy",
false,
newHashSet("DELETE", "COMPACTION"),
"DELETE"
@@ -49,7 +49,7 @@ public class TopicAttributes {
static {
ALL = new HashMap<>();
ALL.put(QUEUE_TYPE_ATTRIBUTE.getName(), QUEUE_TYPE_ATTRIBUTE);
ALL.put(DELETE_POLICY_ATTRIBUTE.getName(), DELETE_POLICY_ATTRIBUTE);
ALL.put(CLEANUP_POLICY_ATTRIBUTE.getName(), CLEANUP_POLICY_ATTRIBUTE);
ALL.put(TOPIC_MESSAGE_TYPE_ATTRIBUTE.getName(), TOPIC_MESSAGE_TYPE_ATTRIBUTE);
}
}
common/src/main/java/org/apache/rocketmq/common/utils/DeletePolicyUtils.java
+4 -4
View File
@@ -31,20 +31,20 @@ public class DeletePolicyUtils {
public static CleanupPolicy getDeletePolicy(Optional<TopicConfig> topicConfig) {
if (!topicConfig.isPresent()) {
return CleanupPolicy.valueOf(TopicAttributes.DELETE_POLICY_ATTRIBUTE.getDefaultValue());
return CleanupPolicy.valueOf(TopicAttributes.CLEANUP_POLICY_ATTRIBUTE.getDefaultValue());
}
String attributeName = TopicAttributes.DELETE_POLICY_ATTRIBUTE.getName();
String attributeName = TopicAttributes.CLEANUP_POLICY_ATTRIBUTE.getName();
Map<String, String> attributes = topicConfig.get().getAttributes();
if (attributes == null || attributes.size() == 0) {
return CleanupPolicy.valueOf(TopicAttributes.DELETE_POLICY_ATTRIBUTE.getDefaultValue());
return CleanupPolicy.valueOf(TopicAttributes.CLEANUP_POLICY_ATTRIBUTE.getDefaultValue());
}
if (attributes.containsKey(attributeName)) {
return CleanupPolicy.valueOf(attributes.get(attributeName));
} else {
return CleanupPolicy.valueOf(TopicAttributes.DELETE_POLICY_ATTRIBUTE.getDefaultValue());
return CleanupPolicy.valueOf(TopicAttributes.CLEANUP_POLICY_ATTRIBUTE.getDefaultValue());
}
}
}