From 31a3d28d48d05937f9601ebf1f8ba230ee25864e Mon Sep 17 00:00:00 2001 From: 101captain <237651143@qq.com> Date: 星期五, 08 四月 2022 11:02:49 +0800 Subject: [PATCH] 花城消息队列修改提交 --- springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/McsOrderServiceImpl.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/McsOrderServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/McsOrderServiceImpl.java index d519b32..b8c4da8 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/McsOrderServiceImpl.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/McsOrderServiceImpl.java @@ -80,7 +80,7 @@ mcsOrder.setCreateTime(new Date()); mcsOrder.setOrderNo(DateUtils.getCurrentDateStrNoSignal()); this.baseMapper.insert(mcsOrder); - rabbitTemplate.convertAndSend("mcsOrder.exchange", "mcsOrder.key", mcsOrder, message -> { + rabbitTemplate.convertAndSend("huacheng.mcsOrder.exchange", "huacheng.mcsOrder.key", mcsOrder, message -> { message.getMessageProperties().setHeader("x-delay", 1000 * 1800); return message; }); -- Gitblit v1.7.1