diff --git a/hippo4j-message/src/main/java/cn/hippo4j/message/service/Hippo4jBaseSendMessageService.java b/hippo4j-message/src/main/java/cn/hippo4j/message/service/Hippo4jBaseSendMessageService.java index 10b131ce..30493e82 100644 --- a/hippo4j-message/src/main/java/cn/hippo4j/message/service/Hippo4jBaseSendMessageService.java +++ b/hippo4j-message/src/main/java/cn/hippo4j/message/service/Hippo4jBaseSendMessageService.java @@ -94,7 +94,7 @@ public class Hippo4jBaseSendMessageService implements Hippo4jSendMessageService, } messageHandler.sendChangeMessage(each, changeParameterNotifyRequest); } catch (Exception ex) { - log.warn("Failed to send thread pool change notification. key: [{}]", threadPoolId, ex); + log.error("Failed to send thread pool change notification. key: [{}]", threadPoolId, ex); } }); } @@ -116,8 +116,10 @@ public class Hippo4jBaseSendMessageService implements Hippo4jSendMessageService, return; } messageHandler.sendWebChangeMessage(each, webChangeParameterNotifyRequest); + } catch (IllegalAccessException ex) { + log.warn("Failed to send thread pool change notification. key: [{}]", threadPoolId); } catch (Exception ex) { - log.warn("Failed to send thread pool change notification. key: [{}]", threadPoolId, ex); + log.error("Failed to send thread pool change notification. key: [{}]", threadPoolId, ex); } }); }