From 63d17a6073086641f3fe7ff3b688c1b0349cab74 Mon Sep 17 00:00:00 2001 From: jianjun Date: Fri, 24 Dec 2021 18:52:27 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B4=B9=E5=8A=B2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/epmet/service/impl/SystemMessageServiceImpl.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/SystemMessageServiceImpl.java b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/SystemMessageServiceImpl.java index a6d2d1d852..a5c07f9ea1 100644 --- a/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/SystemMessageServiceImpl.java +++ b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/SystemMessageServiceImpl.java @@ -19,6 +19,7 @@ import com.epmet.service.SystemMessageService; import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor; +import org.apache.commons.lang3.StringUtils; import org.apache.rocketmq.client.exception.MQClientException; import org.apache.rocketmq.common.message.Message; import org.apache.rocketmq.remoting.common.RemotingHelper; @@ -109,6 +110,10 @@ public class SystemMessageServiceImpl implements SystemMessageService { private void sendMQMessage(String messageType, String contentStr, String penddingId) { String topic = getTopicByMsgType(messageType); + if (StringUtils.isBlank(topic)){ + logger.warn("topic is not match,messageType:{}", messageType); + return; + } // 缓存下来，供滞留消息扫描。TTL -1，永不过期 String pendingMsgLabel = null; @@ -207,7 +212,7 @@ public class SystemMessageServiceImpl implements SystemMessageService { topic=TopicConstants.CAL_PARTY_UNIT_SATISFACTION; break; default: - logger.warn("getTopicByMsgType default msgType:{}", msgType); + logger.error("getTopicByMsgType msgType:{} is not support for any topic", msgType); } return topic; }