We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e5e0905 commit 8deb3c1Copy full SHA for 8deb3c1
store/src/main/java/org/apache/rocketmq/store/CommitLog.java
@@ -174,17 +174,6 @@ public boolean load() {
174
return result;
175
}
176
177
- public void cleanResourceAll() {
178
- // Clean all mapped file resources
179
- if (mappedFileQueue != null) {
180
- for (MappedFile mappedFile : mappedFileQueue.getMappedFiles()) {
181
- if (mappedFile instanceof ReferenceResource) {
182
- ((ReferenceResource) mappedFile).cleanup(0);
183
- }
184
185
186
187
-
188
public void start() {
189
this.flushManager.start();
190
log.info("start commitLog successfully. storeRoot: {}", this.defaultMessageStore.getMessageStoreConfig().getStorePathRootDir());
0 commit comments