From ec0a90ab01fb920fb835fbdfcb89ab7697301c2e Mon Sep 17 00:00:00 2001 From: "chen.ma" Date: Sat, 13 Aug 2022 18:03:41 +0800 Subject: [PATCH] Dynamically register alarm logic changes --- .../starter/support/DynamicThreadPoolConfigService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hippo4j-spring-boot/hippo4j-core-spring-boot-starter/src/main/java/cn/hippo4j/core/springboot/starter/support/DynamicThreadPoolConfigService.java b/hippo4j-spring-boot/hippo4j-core-spring-boot-starter/src/main/java/cn/hippo4j/core/springboot/starter/support/DynamicThreadPoolConfigService.java index 30b26bef..44bf20a8 100644 --- a/hippo4j-spring-boot/hippo4j-core-spring-boot-starter/src/main/java/cn/hippo4j/core/springboot/starter/support/DynamicThreadPoolConfigService.java +++ b/hippo4j-spring-boot/hippo4j-core-spring-boot-starter/src/main/java/cn/hippo4j/core/springboot/starter/support/DynamicThreadPoolConfigService.java @@ -52,7 +52,7 @@ public class DynamicThreadPoolConfigService extends AbstractDynamicThreadPoolSer // Register properties. GlobalCoreThreadPoolManage.register(threadPoolId, executorProperties); DynamicThreadPoolRegisterCoreNotifyParameter notifyParameter = registerWrapper.getDynamicThreadPoolRegisterCoreNotifyParameter(); - ThreadPoolNotifyAlarm notifyAlarm = new ThreadPoolNotifyAlarm(true, notifyParameter.getActiveAlarm(), notifyParameter.getCapacityAlarm()); + ThreadPoolNotifyAlarm notifyAlarm = new ThreadPoolNotifyAlarm(true, registerParameter.getActiveAlarm(), registerParameter.getCapacityAlarm()); notifyAlarm.setReceives(notifyParameter.getReceives()); notifyAlarm.setInterval(notifyParameter.getInterval()); // Register notify.