From 77a5ab85c55cdd84b311b1d67d35ba4663be8b93 Mon Sep 17 00:00:00 2001
From: dengzedong <dengzedong@email>
Date: 星期五, 06 十二月 2024 12:00:35 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/config/TopicPredictFinishRabbitConfig.java | 7 +++----
1 files changed, 3 insertions(+), 4 deletions(-)
diff --git a/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/config/TopicPredictFinishRabbitConfig.java b/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/config/TopicPredictFinishRabbitConfig.java
index c67a5b6..110fbe8 100644
--- a/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/config/TopicPredictFinishRabbitConfig.java
+++ b/shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/config/TopicPredictFinishRabbitConfig.java
@@ -23,15 +23,14 @@
return new Queue(TopicPredictFinishRabbitConfig.routingPredictFinish);
}
-
@Bean
- TopicExchange exchange() {
+ TopicExchange predictFinishExchange() {
return new TopicExchange(PredictFinishMessage.EXCHANGE);
}
// 注意通配符*和#的用法
@Bean
- Binding bindingExchangeMessageDH() {
- return BindingBuilder.bind(predictFinishQueue()).to(exchange()).with(routingPredictFinish);
+ Binding bindingExchangeMessagePF() {
+ return BindingBuilder.bind(predictFinishQueue()).to(predictFinishExchange()).with(routingPredictFinish);
}
}
--
Gitblit v1.9.3