费劲

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;
     }