chengf
2026-01-27 b6184e2ddf3db37a94f7efb3b619bbc64642a292
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;
    }
}