diff --git a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/ding/DingAlarmConstants.java b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/ding/DingAlarmConstants.java index 32ed3394..59119cda 100644 --- a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/ding/DingAlarmConstants.java +++ b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/ding/DingAlarmConstants.java @@ -65,6 +65,7 @@ public class DingAlarmConstants { " --- \n\n " + "核心线程数:%s \n\n " + "最大线程数:%s \n\n " + + "核心线程超时:%s \n\n " + "线程存活时间:%s / SECONDS \n\n" + " --- \n\n " + "队列类型:%s \n\n " + diff --git a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/ding/DingSendMessageHandler.java b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/ding/DingSendMessageHandler.java index 72c944b1..d2612c5b 100644 --- a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/ding/DingSendMessageHandler.java +++ b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/ding/DingSendMessageHandler.java @@ -1,5 +1,6 @@ package cn.hippo4j.starter.alarm.ding; +import cn.hippo4j.common.enums.EnableEnum; import cn.hippo4j.common.model.InstanceInfo; import cn.hippo4j.common.model.PoolParameterInfo; import cn.hippo4j.starter.alarm.NotifyDTO; @@ -138,6 +139,8 @@ public class DingSendMessageHandler implements SendMessageHandler { customPool.getCorePoolSize() + " ➲ " + parameter.getCoreSize(), // 最大线程数 customPool.getMaximumPoolSize() + " ➲ " + parameter.getMaxSize(), + // 核心线程超时 + customPool.allowsCoreThreadTimeOut() + " ➲ " + EnableEnum.getBool(parameter.getAllowCoreThreadTimeOut()), // 线程存活时间 customPool.getKeepAliveTime(TimeUnit.SECONDS) + " ➲ " + parameter.getKeepAliveTime(), // 阻塞队列 diff --git a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/wechat/WeChatAlarmConstants.java b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/wechat/WeChatAlarmConstants.java index 3f4c6107..66fffa69 100644 --- a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/wechat/WeChatAlarmConstants.java +++ b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/wechat/WeChatAlarmConstants.java @@ -48,6 +48,7 @@ public class WeChatAlarmConstants { "> 应用实例:%s \n" + "> 核心线程数:%s \n" + "> 最大线程数:%s \n" + + "> 核心线程超时:%s \n" + "> 线程存活时间:%s / SECONDS \n" + "> 队列类型:%s \n" + "> 队列容量:%s \n" + diff --git a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/wechat/WeChatSendMessageHandler.java b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/wechat/WeChatSendMessageHandler.java index 0009d5b6..da03dd77 100644 --- a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/wechat/WeChatSendMessageHandler.java +++ b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/wechat/WeChatSendMessageHandler.java @@ -1,5 +1,6 @@ package cn.hippo4j.starter.alarm.wechat; +import cn.hippo4j.common.enums.EnableEnum; import cn.hippo4j.common.model.InstanceInfo; import cn.hippo4j.common.model.PoolParameterInfo; import cn.hippo4j.common.toolkit.JSONUtil; @@ -126,6 +127,8 @@ public class WeChatSendMessageHandler implements SendMessageHandler { customPool.getCorePoolSize() + " ➲ " + parameter.getCoreSize(), // 最大线程数 customPool.getMaximumPoolSize() + " ➲ " + parameter.getMaxSize(), + // 核心线程超时 + customPool.allowsCoreThreadTimeOut() + " ➲ " + EnableEnum.getBool(parameter.getAllowCoreThreadTimeOut()), // 线程存活时间 customPool.getKeepAliveTime(TimeUnit.SECONDS) + " ➲ " + parameter.getKeepAliveTime(), // 阻塞队列