Skip to content

R
Rocketmq

Kwan的解忧杂货铺@新空间代码工作室 / Rocketmq
与 Fork 源项目一致

Fork自 Apache RocketMQ / Rocketmq

通知 1
Star 0
Fork 0
R
Rocketmq
提交 28a0906b 编写于 作者: D dongeforever
浏览文件
操作

Polish file reserved hours to 24 * 365 * 10 when disableDeleteDLedger

上级 3f0b0b23
隐藏空白更改
内联 并排
Showing with 2 addition and 1 deletion
store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
浏览文件 @ 28a0906b
...@@ -75,6 +75,7 @@ public class DLedgerCommitLog extends CommitLog { ...@@ -75,6 +75,7 @@ public class DLedgerCommitLog extends CommitLog {
super(defaultMessageStore); super(defaultMessageStore);
dLedgerConfig = new DLedgerConfig(); dLedgerConfig = new DLedgerConfig();
dLedgerConfig.setEnableDiskForceClean(defaultMessageStore.getMessageStoreConfig().isCleanFileForciblyEnable()); dLedgerConfig.setEnableDiskForceClean(defaultMessageStore.getMessageStoreConfig().isCleanFileForciblyEnable());
dLedgerConfig.setStoreType(DLedgerConfig.FILE);
dLedgerConfig.setSelfId(defaultMessageStore.getMessageStoreConfig().getdLegerSelfId()); dLedgerConfig.setSelfId(defaultMessageStore.getMessageStoreConfig().getdLegerSelfId());
dLedgerConfig.setGroup(defaultMessageStore.getMessageStoreConfig().getdLegerGroup()); dLedgerConfig.setGroup(defaultMessageStore.getMessageStoreConfig().getdLegerGroup());
dLedgerConfig.setPeers(defaultMessageStore.getMessageStoreConfig().getdLegerPeers()); dLedgerConfig.setPeers(defaultMessageStore.getMessageStoreConfig().getdLegerPeers());
...@@ -114,7 +115,7 @@ public class DLedgerCommitLog extends CommitLog { ...@@ -114,7 +115,7 @@ public class DLedgerCommitLog extends CommitLog {
private void disableDeleteDledger() { private void disableDeleteDledger() {
dLedgerConfig.setEnableDiskForceClean(false); dLedgerConfig.setEnableDiskForceClean(false);
dLedgerConfig.setFileReservedHours(Integer.MAX_VALUE); dLedgerConfig.setFileReservedHours(24 * 365 * 10);
} }
@Override @Override
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或