From 3a9d8ba20471ffc23380985a5df55a2f37efed20 Mon Sep 17 00:00:00 2001
From: APLS <html6@msn.com>
Date: Mon, 24 Aug 2020 02:27:40 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E8=B7=AF=E7=94=B1key?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/io/qyi/e5/config/rabbitMQ/RabbitMQConfig.java | 2 +-
 src/main/java/io/qyi/e5/service/task/impl/TaskImpl.java     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/io/qyi/e5/config/rabbitMQ/RabbitMQConfig.java b/src/main/java/io/qyi/e5/config/rabbitMQ/RabbitMQConfig.java
index b1fb8ee..fa7aa77 100644
--- a/src/main/java/io/qyi/e5/config/rabbitMQ/RabbitMQConfig.java
+++ b/src/main/java/io/qyi/e5/config/rabbitMQ/RabbitMQConfig.java
@@ -56,7 +56,7 @@ public class RabbitMQConfig {
     //绑定  将队列和交换机绑定,
     @Bean
     public Binding bindingFanoutQueue1() {
-        return BindingBuilder.bind(fanoutQueue1()).to(customExchangeDelay()).with("delay3").noargs();
+        return BindingBuilder.bind(fanoutQueue1()).to(customExchangeDelay()).with("routing_delay").noargs();
     }
 
 
diff --git a/src/main/java/io/qyi/e5/service/task/impl/TaskImpl.java b/src/main/java/io/qyi/e5/service/task/impl/TaskImpl.java
index a3f2b2c..f17ec95 100644
--- a/src/main/java/io/qyi/e5/service/task/impl/TaskImpl.java
+++ b/src/main/java/io/qyi/e5/service/task/impl/TaskImpl.java
@@ -102,7 +102,7 @@ public class TaskImpl implements ITask {
     public void send(Object msg, int Expiration) {
         CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
 
-        rabbitTemplate.convertAndSend("delay", "delay", msg, message -> {
+        rabbitTemplate.convertAndSend("delay", "routing_delay", msg, message -> {
             MessageProperties messageProperties = message.getMessageProperties();
             // 设置这条消息的过期时间
 //            messageProperties.setExpiration(Expiration);