From cb568c56464cd0ed744f5740741a388dd1d2a019 Mon Sep 17 00:00:00 2001
From: gaoqr <13665037151@163.com>
Date: Wed, 14 May 2025 09:32:18 +0800
Subject: [PATCH] =?UTF-8?q?system=20rabbitmq=E9=98=9F=E5=88=97=E5=A3=B0?=
 =?UTF-8?q?=E6=98=8E=E6=9A=82=E6=B3=A8=E9=87=8A?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ChenfengRabbitMQSystemConfiguration.java  | 52 +++++++++----------
 1 file changed, 26 insertions(+), 26 deletions(-)

diff --git a/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/config/ChenfengRabbitMQSystemConfiguration.java b/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/config/ChenfengRabbitMQSystemConfiguration.java
index 92d407f12..086830186 100644
--- a/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/config/ChenfengRabbitMQSystemConfiguration.java
+++ b/cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/config/ChenfengRabbitMQSystemConfiguration.java
@@ -25,30 +25,30 @@ public class ChenfengRabbitMQSystemConfiguration {
     /**
      * 广告状态修改 延迟队列
      */
-    @Bean
-    public Queue advertisementUpdateDelayedQueue(){
-        return QueueBuilder.durable(SYSTEM_ADVERTISEMENT_UPDATE_DELAYED_QUEUE).build();
-    }
-
-    /**
-     * 广告状态修改 定义延迟交换机
-     */
-    @Bean
-    public CustomExchange advertisementUpdateDelayExchange() {
-        Map<String, Object> args = new HashMap<>();
-        args.put("x-delayed-type", "direct");
-        return new CustomExchange(SYSTEM_ADVERTISEMENT_UPDATE_DELAYED_EXCHANGE, "x-delayed-message", true, false, args);
-    }
-
-    /**
-     * 广告状态修改 队列与交换机绑定
-     */
-    @Bean
-    public Binding advertisementUpdateQueueABindingX(@Qualifier("advertisementUpdateDelayedQueue") Queue queue,
-                                                     @Qualifier("advertisementUpdateDelayExchange") CustomExchange delayedExchange){
-        return BindingBuilder.bind(queue)
-                .to(delayedExchange)
-                .with(SYSTEM_ADVERTISEMENT_UPDATE_DELAYED_ROUTING_KEY)
-                .noargs();
-    }
+//    @Bean
+//    public Queue advertisementUpdateDelayedQueue(){
+//        return QueueBuilder.durable(SYSTEM_ADVERTISEMENT_UPDATE_DELAYED_QUEUE).build();
+//    }
+//
+//    /**
+//     * 广告状态修改 定义延迟交换机
+//     */
+//    @Bean
+//    public CustomExchange advertisementUpdateDelayExchange() {
+//        Map<String, Object> args = new HashMap<>();
+//        args.put("x-delayed-type", "direct");
+//        return new CustomExchange(SYSTEM_ADVERTISEMENT_UPDATE_DELAYED_EXCHANGE, "x-delayed-message", true, false, args);
+//    }
+//
+//    /**
+//     * 广告状态修改 队列与交换机绑定
+//     */
+//    @Bean
+//    public Binding advertisementUpdateQueueABindingX(@Qualifier("advertisementUpdateDelayedQueue") Queue queue,
+//                                                     @Qualifier("advertisementUpdateDelayExchange") CustomExchange delayedExchange){
+//        return BindingBuilder.bind(queue)
+//                .to(delayedExchange)
+//                .with(SYSTEM_ADVERTISEMENT_UPDATE_DELAYED_ROUTING_KEY)
+//                .noargs();
+//    }
 }