修复等待时间

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

@@ -84,20 +84,17 @@ public class MessageSendServiceImpl implements MessageSendService {
         // 设置编号
         CorrelationData correlationData = new CorrelationData();
         correlationData.setId(finalMessageId);
-        rabbitTemplate.getRabbitTemplate().convertAndSend(req.getExchangeName(), req.getRouteKey(), req.getMessage(), new MessagePostProcessor() {
-            @Override
-            public Message postProcessMessage(Message message) throws AmqpException {
-                // 设置队列消息持久化
-                MessageProperties properties = message.getMessageProperties();
-                // 设置持久化
-                properties.setDeliveryMode(MessageDeliveryMode.PERSISTENT);
-                // 设置消息编号
-                properties.setMessageId(StringHelper.getIdShort(finalMessageId, TEMP_ID));
-                if (req.getDedTime() > 0) {
-                    properties.setExpiration(req.getDedTime() + "");
-                }
-                return message;
+        rabbitTemplate.getRabbitTemplate().convertAndSend(req.getExchangeName(), req.getRouteKey(), req.getMessage(), message -> {
+            // 设置队列消息持久化
+            MessageProperties properties = message.getMessageProperties();
+            // 设置持久化
+            properties.setDeliveryMode(MessageDeliveryMode.PERSISTENT);
+            // 设置消息编号
+            properties.setMessageId(StringHelper.getIdShort(finalMessageId, TEMP_ID));
+            if (req.getDedTime() > 0) {
+                properties.setExpiration(req.getDedTime() + "");
             }
+            return message;
         }, correlationData);
         return req.getMessageId();
     }