数据rabbitmq队列丢弃垃圾数据

sms_water/src/main/java/com/huaxu/rabbitmq/ReceiveData.java

@@ -90,7 +90,7 @@ public class ReceiveData {
         } catch (Exception e) {
             log.error(ExceptionUtils.getStackTrace(e));
             // 发送异常时消息返回队列
-            receiveDataRabbitTemplate.convertAndSend(rabbitmqQueue, receivedData);
+//            receiveDataRabbitTemplate.convertAndSend(rabbitmqQueue, receivedData);
         }
 
     }

sms_water/src/main/resources/application-dev.properties

@@ -128,6 +128,7 @@ message.spring.rabbitmq.listener.simple.acknowledge-mode = NONE
 message.spring.rabbitmq.listener.simple.prefetch = 20
 message.spring.rabbitmq.connection-timeout=15000
 message.spring.rabbitmq.publisher-confirm-type=correlated
+message.spring.rabbitmq.publisher-confirms=true
 message.spring.rabbitmq.publisher-returns=true
 
 dispath.queue=dispath