autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-04-21 11:35:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

update 注册消息队列

Browse Source
This commit is contained in:
Guoqs
2025-08-11 15:46:24 +08:00
parent 66fe563a04
commit 247f55f62f
3 changed files with 18 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
jsowell-common/src/main/java/com/jsowell/common/config/mq/DirectRabbitConfig.java
View File

@@ -35,10 +35,10 @@ public class DirectRabbitConfig {
// return new Queue(RabbitConstants.QUEUE_HEART_BEAT);
// }
//
// @Bean
// public Queue realtimeDataQueue() {
// return new Queue(RabbitConstants.QUEUE_REALTIME_DATA);
// }
@Bean
public Queue realtimeDataQueue() {
return new Queue(RabbitConstants.QUEUE_REALTIME_DATA);
}
//
// @Bean
// public Queue priceSenderQueue() {
@@ -88,10 +88,10 @@ public class DirectRabbitConfig {
// return BindingBuilder.bind(heartBeatQueue()).to(exchange()).with(RabbitConstants.QUEUE_HEART_BEAT);
// }
//
// @Bean
// public Binding bindRealtimeData() {
// return BindingBuilder.bind(realtimeDataQueue()).to(exchange()).with(RabbitConstants.QUEUE_REALTIME_DATA);
// }
@Bean
public Binding bindRealtimeData() {
return BindingBuilder.bind(realtimeDataQueue()).to(exchange()).with(RabbitConstants.QUEUE_REALTIME_DATA);
}
//
// @Bean
// public Binding bindPriceSender() {