处理MQ操作retry功能机制

imcs-admin-boot/imcs-business-biz/src/main/java/com/github/zuihou/business/mq/ConsumerHandler.java

@@ -41,12 +41,12 @@ public class ConsumerHandler implements ChannelAwareMessageListener {
         } catch(Exception e){
             log.error("MQ异常:"+e.getMessage());
             //是否重试请求
-            if (message.getMessageProperties().getRedelivered()) {
-                channel.basicNack(deliveryTag, false, false);//消息消费失败将丢弃该消息
-            }else{
-                log.error("消息消费失败将丢弃该消息");
+            //if (message.getMessageProperties().getRedelivered()) {
+            //    channel.basicNack(deliveryTag, false, false);//消息消费失败将丢弃该消息
+            //}else{
+                log.error("消息消费失败重新进入队列");
                 channel.basicNack(deliveryTag, false, true);
-            }
+            //}
         }
     }