升级新版本

b4f5c796 · yanzg · c26c1551 · b4f5c796
Commit b4f5c796 authored Sep 13, 2022 by yanzg
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

MqServiceImpl.java ...n/java/com/yanzuoguang/mq/service/impl/MqServiceImpl.java +1 -1

No files found.
--- a/yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MqServiceImpl.java
+++ b/yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MqServiceImpl.java
@@ -132,7 +132,7 @@ public class MqServiceImpl implements MqService {
            if (StringHelper.isEmpty(exchangeName, routeKey)) {
                return;
            }
-            this.message(new MessageVo(exchangeName, routeKey, message, dedTime));
+            this.message(new MessageVo(exchangeName, routeKey, message, dedTime, MessageVo.DED_TIME_TYPE_PRIVATE));
        } finally {
            this.basicAck(messageBody, channel);
        }