package com.java110.job.databus;
|
|
import com.java110.core.factory.GenerateCodeFactory;
|
import com.java110.core.log.LoggerFactory;
|
import com.java110.dto.data.DatabusQueueDataDto;
|
import org.slf4j.Logger;
|
|
import java.util.concurrent.BlockingQueue;
|
import java.util.concurrent.LinkedBlockingQueue;
|
import java.util.concurrent.TimeUnit;
|
|
public class DatabusDataQueue {
|
private static final Logger log = LoggerFactory.getLogger(DatabusDataQueue.class);
|
|
private static final BlockingQueue<DatabusQueueDataDto> msgs = new LinkedBlockingQueue<DatabusQueueDataDto>(100);
|
|
/**
|
* 添加导出数据消息
|
*
|
* @param databusQueueDataDto
|
*/
|
public static void addMsg(DatabusQueueDataDto databusQueueDataDto) throws Exception {
|
msgs.offer(databusQueueDataDto, 3, TimeUnit.SECONDS);
|
|
}
|
|
public static DatabusQueueDataDto getData() throws Exception {
|
return msgs.take();
|
|
}
|
|
}
|
