From 626bb3aa189053a742cf04f66929f2a54fc9695c Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期四, 04 七月 2024 15:38:21 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/dev' into dev
---
src/main/java/com/ycl/jxkg/rabbitmq/RabbitMQConfig.java | 11 +++++++++++
1 files changed, 11 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/ycl/jxkg/rabbitmq/RabbitMQConfig.java b/src/main/java/com/ycl/jxkg/rabbitmq/RabbitMQConfig.java
index 91bf54c..47ff879 100644
--- a/src/main/java/com/ycl/jxkg/rabbitmq/RabbitMQConfig.java
+++ b/src/main/java/com/ycl/jxkg/rabbitmq/RabbitMQConfig.java
@@ -25,6 +25,11 @@
@Autowired
private ConnectionFactory connectionFactory;
+ @Bean
+ public DirectExchange examExchange() {
+ return new DirectExchange("examExchange");
+ }
+
// 鍒涘缓鏅�氶槦鍒�
@Bean
public Queue examQueue() {
@@ -34,6 +39,12 @@
return new Queue("jxkg", true, false, false, args);
}
+ // 鏅�氫俊闃熷垪鍒颁氦鎹㈡満
+ @Bean
+ public Binding binding(Queue examQueue, DirectExchange examExchange) {
+ return BindingBuilder.bind(examQueue).to(examExchange).with("exam");
+ }
+
// 鍒涘缓姝讳俊浜ゆ崲鏈�
@Bean
public DirectExchange dlxExchange() {
--
Gitblit v1.8.0