升级新版本

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/MqService.java

@@ -76,6 +76,18 @@ public interface MqService {
     @ApiOperation(value = "消息收到确认")
     void basicHandle(Message messageBody, Channel channel, String message, Consumer<String> consumerMessage);
 
+    /**
+     * 消息收到确认，出错时不需要重发
+     *
+     * @param messageBody     消息体
+     * @param channel         　收到的通道
+     * @param message         　消息内容
+     * @param dedTime         　消息延迟处理时间
+     * @param consumerMessage 消费者，具体业务处理函数
+     */
+    @ApiOperation(value = "消息收到确认")
+    void basicHandle(Message messageBody, Channel channel, String message, long dedTime, Consumer<String> consumerMessage);
+
 
     /**
      * 消息收到确认,出错时重发

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MqServiceImpl.java

@@ -111,9 +111,15 @@ public class MqServiceImpl implements MqService {
         this.basicHandle(messageBody, channel, consumerQueue, consumerQueue, message, 0, consumerMessage);
     }
 
+    @Override
+    public void basicHandle(Message messageBody, Channel channel, String message, long dedTime, Consumer<String> consumerMessage) {
+        String consumerQueue = messageBody.getMessageProperties().getConsumerQueue();
+        this.basicHandle(messageBody, channel, consumerQueue, consumerQueue, message, dedTime, consumerMessage);
+    }
+
     @Override
     public void basicHandle(Message messageBody, Channel channel, String exchangeNameAndRouteKey, String message, Consumer<String> consumerMessage) {
-        this.basicHandle(messageBody, channel, exchangeNameAndRouteKey, exchangeNameAndRouteKey, message, 60 * 1000, consumerMessage);
+        this.basicHandle(messageBody, channel, exchangeNameAndRouteKey, exchangeNameAndRouteKey, message, 0, consumerMessage);
     }
 
     @Override