From 87c0a03162bc9ee52c6ba920b27eb7d42b02fb8d Mon Sep 17 00:00:00 2001 From: nowinkey Date: Wed, 8 Feb 2023 10:23:17 +0800 Subject: [PATCH] Refactor LOGGER.warn() --- .../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 f12a90eeac..baa71e1bab 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); } }