fix bug (#899)

3 years ago · 18b2a9bc36
parent b73725f159
commit 18b2a9bc36
1 changed files with 1 additions and 1 deletions
--- a/hippo4j-core/src/main/java/cn/hippo4j/core/executor/ThreadPoolNotifyAlarmHandler.java
+++ b/hippo4j-core/src/main/java/cn/hippo4j/core/executor/ThreadPoolNotifyAlarmHandler.java
@ -124,7 +124,7 @@ public class ThreadPoolNotifyAlarmHandler implements Runnable, CommandLineRunner
     */
    public void checkPoolActivityAlarm(String threadPoolId, ThreadPoolExecutor threadPoolExecutor) {
        ThreadPoolNotifyAlarm alarmConfig = GlobalNotifyAlarmManage.get(threadPoolId);
-        if (Objects.isNull(alarmConfig) || !alarmConfig.getAlarm() || alarmConfig.getCapacityAlarm() <= 0) {
+        if (Objects.isNull(alarmConfig) || !alarmConfig.getAlarm() || alarmConfig.getActiveAlarm() <= 0) {
            return;
        }
        int activeCount = threadPoolExecutor.getActiveCount();