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; } }