msb-public
/
hippo4j
mirror of https://github.com/longtai-cn/hippo4j
1
0
Code Issues Projects Releases Wiki Activity

Changelog print order

Browse Source
pull/989/head
chen.ma 2 years ago
parent c1de4cda9c
commit b500bd1c65
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File

6
hippo4j-message/src/main/java/cn/hippo4j/message/service/Hippo4jBaseSendMessageService.java
Unescape View File

@ -66,7 +66,7 @@ public class Hippo4jBaseSendMessageService implements Hippo4jSendMessageService,
try { try {
SendMessageHandler messageHandler = sendMessageHandlers.get(each.getPlatform()); SendMessageHandler messageHandler = sendMessageHandlers.get(each.getPlatform());
if (messageHandler == null) { if (messageHandler == null) {
log.warn("Please configure alarm notification on the server. key: [{}]", threadPoolId); log.warn("[{}] Please configure alarm notification on the server.", threadPoolId);
return; return;
} }
if (isSendAlarm(each.getTpId(), each.getPlatform(), typeEnum)) { if (isSendAlarm(each.getTpId(), each.getPlatform(), typeEnum)) {
@ -89,14 +89,14 @@ public class Hippo4jBaseSendMessageService implements Hippo4jSendMessageService,
.toString(); .toString();
List<NotifyConfigDTO> notifyList = notifyConfigs.get(buildKey); List<NotifyConfigDTO> notifyList = notifyConfigs.get(buildKey);
if (CollectionUtil.isEmpty(notifyList)) { if (CollectionUtil.isEmpty(notifyList)) {
log.warn("Please configure alarm notification on the server. key: [{}]", threadPoolId); log.warn("[{}] Please configure alarm notification on the server.", threadPoolId);
return; return;
} }
notifyList.forEach(each -> { notifyList.forEach(each -> {
try { try {
SendMessageHandler messageHandler = sendMessageHandlers.get(each.getPlatform()); SendMessageHandler messageHandler = sendMessageHandlers.get(each.getPlatform());
if (messageHandler == null) { if (messageHandler == null) {
log.warn("Please configure alarm notification on the server. key: [{}]", threadPoolId); log.warn("[{}] Please configure alarm notification on the server.", threadPoolId);
return; return;
} }
messageHandler.sendChangeMessage(each, changeParameterNotifyRequest); messageHandler.sendChangeMessage(each, changeParameterNotifyRequest);

Write Preview
Loading…
Cancel
Save