From 000bf38440425f41a5081eb81880c900d06df14a Mon Sep 17 00:00:00 2001 From: "chen.ma" Date: Fri, 26 Nov 2021 21:48:08 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E6=97=A0=E7=94=A8=E4=BB=A3?= =?UTF-8?q?=E7=A0=81.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/cn/hippo4j/starter/alarm/AlarmControlHandler.java | 3 --- .../java/cn/hippo4j/starter/alarm/ThreadPoolAlarmManage.java | 5 ++--- 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/AlarmControlHandler.java b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/AlarmControlHandler.java index 7b0c9249..eae63a4d 100644 --- a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/AlarmControlHandler.java +++ b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/AlarmControlHandler.java @@ -2,7 +2,6 @@ package cn.hippo4j.starter.alarm; import cn.hutool.core.util.IdUtil; import cn.hutool.core.util.StrUtil; -import com.alibaba.fastjson.JSON; import com.google.common.cache.Cache; import com.google.common.collect.Maps; @@ -32,8 +31,6 @@ public class AlarmControlHandler { // val 无意义 cache.put(alarmControl.getTypeEnum().name(), IdUtil.simpleUUID()); return true; - } else { - System.out.println(JSON.toJSONString(alarmControl)); } } diff --git a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/ThreadPoolAlarmManage.java b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/ThreadPoolAlarmManage.java index dd73e404..89bbfd82 100644 --- a/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/ThreadPoolAlarmManage.java +++ b/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/alarm/ThreadPoolAlarmManage.java @@ -28,7 +28,6 @@ public class ThreadPoolAlarmManage { SEND_MESSAGE_SERVICE = Optional.ofNullable(ApplicationContextHolder.getInstance()) .map(each -> each.getBean(MessageAlarmConfig.SEND_MESSAGE_BEAN_NAME, SendMessageService.class)) .orElse(null); - System.out.println(); } /** @@ -72,9 +71,9 @@ public class ThreadPoolAlarmManage { boolean isSend = threadPoolAlarm.getIsAlarm() && divide > threadPoolAlarm.getLivenessAlarm() - && isSendMessage(threadPoolExecutor, MessageTypeEnum.CAPACITY); + && isSendMessage(threadPoolExecutor, MessageTypeEnum.LIVENESS); if (isSend) { - SEND_MESSAGE_SERVICE.sendAlarmMessage(MessageTypeEnum.CAPACITY, threadPoolExecutor); + SEND_MESSAGE_SERVICE.sendAlarmMessage(MessageTypeEnum.LIVENESS, threadPoolExecutor); } }