From f1b2c4f360fdac3c4205d7275f389c4dbff44748 Mon Sep 17 00:00:00 2001 From: cnScarb Date: Thu, 23 Dec 2021 14:26:50 +0800 Subject: [PATCH] Fix spelling error in DefaultMessageStore, use getServiceName for GroupCommitService logging (#3663) --- store/src/main/java/org/apache/rocketmq/store/CommitLog.java | 2 +- .../java/org/apache/rocketmq/store/DefaultMessageStore.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java index 112e9bced4..05ea526c99 100644 --- a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java +++ b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java @@ -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) { diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java index ed882aa681..1f24dc7771 100644 --- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java +++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java @@ -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"); }