You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2022/11/02 12:53:35 UTC
[rocketmq] branch develop updated: [ISSUE #5453]Combine parseDelayLevel error log information (#5454)
This is an automated email from the ASF dual-hosted git repository.
lizhanhui 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 3963c754e [ISSUE #5453]Combine parseDelayLevel error log information (#5454)
3963c754e is described below
commit 3963c754ed20cc5bdaa3e59cc2ebcc832c1d2dc7
Author: mxsm <lj...@gmail.com>
AuthorDate: Wed Nov 2 20:53:28 2022 +0800
[ISSUE #5453]Combine parseDelayLevel error log information (#5454)
---
.../org/apache/rocketmq/broker/schedule/ScheduleMessageService.java | 3 +--
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java | 3 +--
2 files changed, 2 insertions(+), 4 deletions(-)
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java b/broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java
index 9a8721b04..ebfc27f12 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java
@@ -339,8 +339,7 @@ public class ScheduleMessageService extends ConfigManager {
}
}
} catch (Exception e) {
- log.error("parseDelayLevel exception", e);
- log.info("levelString String = {}", levelString);
+ log.error("parse message delay level failed. messageDelayLevel = {}", levelString, e);
return false;
}
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 8bae8d04f..6331307ac 100644
--- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -263,8 +263,7 @@ public class DefaultMessageStore implements MessageStore {
this.delayLevelTable.put(level, delayTimeMillis);
}
} catch (Exception e) {
- LOGGER.error("parseDelayLevel exception", e);
- LOGGER.info("levelString String = {}", levelString);
+ LOGGER.error("parse message delay level failed. messageDelayLevel = {}", levelString, e);
return false;
}