From 3974fad5d836431e417e99220cc07bb5b0aba331 Mon Sep 17 00:00:00 2001
From: zhangback <zhangback@163.com>
Date: 星期一, 08 十二月 2025 14:16:16 +0800
Subject: [PATCH] 提交
---
tms/src/main/java/com/ruoyi/tms/config/TmsRabbitConfig.java | 50 ++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 50 insertions(+), 0 deletions(-)
diff --git a/tms/src/main/java/com/ruoyi/tms/config/TmsRabbitConfig.java b/tms/src/main/java/com/ruoyi/tms/config/TmsRabbitConfig.java
new file mode 100644
index 0000000..ad667b7
--- /dev/null
+++ b/tms/src/main/java/com/ruoyi/tms/config/TmsRabbitConfig.java
@@ -0,0 +1,50 @@
+package com.ruoyi.tms.config;
+
+import org.springframework.amqp.core.*;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+
+@Configuration
+public class TmsRabbitConfig {
+
+ // 寤惰繜闃熷垪浜ゆ崲鏈�
+ @Bean
+ public DirectExchange delayExchange() {
+ return new DirectExchange("car_key_delay_exchange");
+ }
+
+ // 姝讳俊闃熷垪浜ゆ崲鏈�
+ @Bean
+ public DirectExchange deadExchange() {
+ return new DirectExchange("car_key_dead_exchange");
+ }
+
+ // 寤惰繜闃熷垪
+ @Bean
+ public Queue delayQueue() {
+ return QueueBuilder.durable("car_key_delay_queue")
+ .withArgument("x-dead-letter-exchange", "car_key_dead_exchange")
+ .withArgument("x-dead-letter-routing-key", "car_key_dead_routing_key")
+ .build();
+ }
+
+ // 姝讳俊闃熷垪锛堝疄闄呮秷璐归槦鍒楋級
+ @Bean
+ public Queue deadQueue() {
+ return QueueBuilder.durable("car_key_dead_queue").build();
+ }
+
+ // 寤惰繜闃熷垪缁戝畾
+ @Bean
+ public Binding delayBinding() {
+ return BindingBuilder.bind(delayQueue()).to(delayExchange()).with("car_key_delay");
+ }
+
+ // 姝讳俊闃熷垪缁戝畾
+ @Bean
+ public Binding deadBinding() {
+ return BindingBuilder.bind(deadQueue()).to(deadExchange()).with("car_key_dead_routing_key");
+ }
+
+}
--
Gitblit v1.8.0