rabbit: 对 ParameterMissingException 异常不进行延迟消费

src/main/java/com/uas/ps/message/rabbit/InquiryMessageListener.java

@@ -1,6 +1,9 @@
 package com.uas.ps.message.rabbit;
 
+import com.uas.ps.message.exception.ParameterMissingException;
 import com.uas.ps.message.service.MessageService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -12,6 +15,8 @@ import org.springframework.stereotype.Component;
 @Component
 public class InquiryMessageListener extends BaseMessageListener {
 
+    private static final Logger LOGGER = LoggerFactory.getLogger(InquiryMessageListener.class);
+
     @Autowired
     private MessageService messageService;
 
@@ -23,6 +28,12 @@ public class InquiryMessageListener extends BaseMessageListener {
      */
     @Override
     public void processMessage(MessageInfo messageInfo) throws Exception {
-        messageService.saveMessages(messageInfo.getData().toString());
+        try {
+            messageService.saveMessages(messageInfo.getData().toString());
+        } catch (ParameterMissingException e) {
+            // 不对这个异常进行处理
+            LOGGER.info(e.getMessage());
+        }
+
     }
 }