This is an automated email from the ASF dual-hosted git repository. zhouxzhan pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 87c0a03162bc9ee52c6ba920b27eb7d42b02fb8d Author: nowinkey <[email protected]> AuthorDate: Wed Feb 8 10:23:17 2023 +0800 Refactor LOGGER.warn() --- store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 f12a90eea..baa71e1ba 100644 --- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java +++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java @@ -2889,7 +2889,7 @@ public class DefaultMessageStore implements MessageStore { batchDispatchRequestQueue.poll(); } } catch (Exception e) { - LOGGER.warn(e.getMessage()); + DefaultMessageStore.LOGGER.warn(this.getServiceName() + " service has exception. ", e); } }
