1 2 3 4 5 6 7 8 9
package com.java110.job.databus; public class DatabusQueue { public void initExportQueue(){ //启动导出数据线程处理器 DatabusDataExecutor.startQueueDataExecutor(); } }