wuye / MicroCommunit

Blame view

service-job/src/main/java/com/java110/job/databus/DatabusQueueConfig.java 493 Bytes
Edit Raw Normal View History
88e030b7   王彪总   init project 
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;
      }
  }