Public/cf_imes_server
6
0
Fork 0
mirror of http://192.168.1.205:9980/cf_devdept2/cf_imes_server.git synced 2026-08-14 21:52:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

system rabbitmq队列声明暂注释

Browse Source
This commit is contained in:
gaoqr
2025-05-14 09:32:18 +08:00
parent 341fd485b3
commit cb568c5646
1 changed files with 26 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cf-module-system/cf-module-system-biz/src/main/java/com/cf/imes/module/system/config/ChenfengRabbitMQSystemConfiguration.java
+26 -26
View File
@@ -25,30 +25,30 @@ public class ChenfengRabbitMQSystemConfiguration {
/** /**
* 广告状态修改 延迟队列 * 广告状态修改 延迟队列
*/ */
@Bean // @Bean
public Queue advertisementUpdateDelayedQueue(){ // public Queue advertisementUpdateDelayedQueue(){
return QueueBuilder.durable(SYSTEM_ADVERTISEMENT_UPDATE_DELAYED_QUEUE).build(); // return QueueBuilder.durable(SYSTEM_ADVERTISEMENT_UPDATE_DELAYED_QUEUE).build();
} // }
//
/** // /**
* 广告状态修改 定义延迟交换机 // * 广告状态修改 定义延迟交换机
*/ // */
@Bean // @Bean
public CustomExchange advertisementUpdateDelayExchange() { // public CustomExchange advertisementUpdateDelayExchange() {
Map<String, Object> args = new HashMap<>(); // Map<String, Object> args = new HashMap<>();
args.put("x-delayed-type", "direct"); // args.put("x-delayed-type", "direct");
return new CustomExchange(SYSTEM_ADVERTISEMENT_UPDATE_DELAYED_EXCHANGE, "x-delayed-message", true, false, args); // return new CustomExchange(SYSTEM_ADVERTISEMENT_UPDATE_DELAYED_EXCHANGE, "x-delayed-message", true, false, args);
} // }
//
/** // /**
* 广告状态修改 队列与交换机绑定 // * 广告状态修改 队列与交换机绑定
*/ // */
@Bean // @Bean
public Binding advertisementUpdateQueueABindingX(@Qualifier("advertisementUpdateDelayedQueue") Queue queue, // public Binding advertisementUpdateQueueABindingX(@Qualifier("advertisementUpdateDelayedQueue") Queue queue,
@Qualifier("advertisementUpdateDelayExchange") CustomExchange delayedExchange){ // @Qualifier("advertisementUpdateDelayExchange") CustomExchange delayedExchange){
return BindingBuilder.bind(queue) // return BindingBuilder.bind(queue)
.to(delayedExchange) // .to(delayedExchange)
.with(SYSTEM_ADVERTISEMENT_UPDATE_DELAYED_ROUTING_KEY) // .with(SYSTEM_ADVERTISEMENT_UPDATE_DELAYED_ROUTING_KEY)
.noargs(); // .noargs();
} // }
} }