Unified thread pool id

hippo4j-common/src/main/java/cn/hippo4j/common/notify/HippoBaseSendMessageService.java

@@ -49,7 +49,7 @@ public class HippoBaseSendMessageService implements HippoSendMessageService, Com
                     return;
                 }
 
-                if (isSendAlarm(each.getThreadPoolId(), each.getPlatform(), typeEnum)) {
+                if (isSendAlarm(each.getTpId(), each.getPlatform(), typeEnum)) {
                     alarmNotifyRequest.setNotifyTypeEnum(typeEnum);
                     messageHandler.sendAlarmMessage(each, alarmNotifyRequest);
                 }

hippo4j-common/src/main/java/cn/hippo4j/common/notify/NotifyConfigDTO.java

@@ -26,7 +26,7 @@ public class NotifyConfigDTO {
     /**
      * 线程池id
      */
-    private String threadPoolId;
+    private String tpId;
 
     /**
      * 通知平台

hippo4j-spring-boot/hippo4j-core-spring-boot-starter/src/main/java/cn/hippo4j/core/starter/notify/CoreNotifyConfigBuilder.java

@@ -58,7 +58,7 @@ public class CoreNotifyConfigBuilder implements NotifyConfigBuilder {
         for (NotifyPlatformProperties platformProperties : notifyPlatforms) {
             NotifyConfigDTO notifyConfig = new NotifyConfigDTO();
             notifyConfig.setPlatform(platformProperties.getPlatform());
-            notifyConfig.setThreadPoolId(threadPoolId);
+            notifyConfig.setTpId(threadPoolId);
             notifyConfig.setType("ALARM");
             notifyConfig.setSecretKey(platformProperties.getSecretKey());
             int interval = Optional.ofNullable(executor.getNotify())
@@ -76,7 +76,7 @@ public class CoreNotifyConfigBuilder implements NotifyConfigBuilder {
         for (NotifyPlatformProperties platformProperties : notifyPlatforms) {
             NotifyConfigDTO notifyConfig = new NotifyConfigDTO();
             notifyConfig.setPlatform(platformProperties.getPlatform());
-            notifyConfig.setThreadPoolId(threadPoolId);
+            notifyConfig.setTpId(threadPoolId);
             notifyConfig.setType("CONFIG");
             notifyConfig.setSecretKey(platformProperties.getSecretKey());
             notifyConfig.setReceives(buildReceive(executor, platformProperties));
@@ -87,7 +87,7 @@ public class CoreNotifyConfigBuilder implements NotifyConfigBuilder {
         resultMap.forEach(
                 (key, val) -> val.stream()
                         .filter(each -> StrUtil.equals("ALARM", each.getType()))
-                        .forEach(each -> alarmControlHandler.initCacheAndLock(each.getThreadPoolId(), each.getPlatform(), each.getInterval()))
+                        .forEach(each -> alarmControlHandler.initCacheAndLock(each.getTpId(), each.getPlatform(), each.getInterval()))
         );
 
         return resultMap;

hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/starter/notify/ServerNotifyConfigBuilder.java

@@ -68,7 +68,7 @@ public class ServerNotifyConfigBuilder implements NotifyConfigBuilder {
 
             resultMap.forEach((key, val) ->
                     val.stream().filter(each -> StrUtil.equals("ALARM", each.getType()))
-                            .forEach(each -> alarmControlHandler.initCacheAndLock(each.getThreadPoolId(), each.getPlatform(), each.getInterval()))
+                            .forEach(each -> alarmControlHandler.initCacheAndLock(each.getTpId(), each.getPlatform(), each.getInterval()))
             );
         }