You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2021/12/23 06:27:07 UTC
[rocketmq] branch develop updated: Fix spelling error in DefaultMessageStore, use getServiceName for GroupCommitService logging (#3663)
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new f1b2c4f Fix spelling error in DefaultMessageStore, use getServiceName for GroupCommitService logging (#3663)
f1b2c4f is described below
commit f1b2c4f360fdac3c4205d7275f389c4dbff44748
Author: cnScarb <jj...@163.com>
AuthorDate: Thu Dec 23 14:26:50 2021 +0800
Fix spelling error in DefaultMessageStore, use getServiceName for GroupCommitService logging (#3663)
---
store/src/main/java/org/apache/rocketmq/store/CommitLog.java | 2 +-
.../src/main/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 112e9bc..05ea526 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 ed882aa..1f24dc7 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");
}