wuxw
2024-01-22 a40c2eb885bcdb697c2e16dae4f43cb6cd718973
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
package com.java110.job.databus;
 
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
/**
 * 消息队里 可以少量小区时 使用如果 小区数量比较大时 可以选择切换为mq
 *
 */
@Configuration
public class DatabusQueueConfig {
 
 
    @Bean
    public DatabusQueue databusQueue(){
        DatabusQueue databusQueue = new DatabusQueue();
        databusQueue.initExportQueue();
        return databusQueue;
    }
}