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

Fix spelling error in DefaultMessageStore, use getServiceName for GroupCommitService logging (#3663)

Browse Source
This commit is contained in:
cnScarb
2021-12-23 14:26:50 +08:00
committed by GitHub
parent 0bc011cef3
commit f1b2c4f360
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
store/src/main/java/org/apache/rocketmq/store/CommitLog.java
+1 -1
View File
@@ -1228,7 +1228,7 @@ public class CommitLog {
try {
Thread.sleep(10);
} catch (InterruptedException e) {
CommitLog.log.warn("GroupCommitService Exception, ", e);
CommitLog.log.warn(this.getServiceName() + " Exception, ", e);
}
synchronized (this) {
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+2 -2
View File
@@ -924,7 +924,7 @@ public class DefaultMessageStore implements MessageStore {
@Override
public void executeDeleteFilesManually() {
this.cleanCommitLogService.excuteDeleteFilesManualy();
this.cleanCommitLogService.executeDeleteFilesManually();
}
@Override
@@ -1590,7 +1590,7 @@ public class DefaultMessageStore implements MessageStore {
private volatile boolean cleanImmediately = false;
public void excuteDeleteFilesManualy() {
public void executeDeleteFilesManually() {
this.manualDeleteFileSeveralTimes = MAX_MANUAL_DELETE_FILE_TIMES;
DefaultMessageStore.log.info("executeDeleteFilesManually was invoked");
}