| | |
|---|
| | | 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; |
|---|
| | |
|---|
| | | * @param databusQueueDataDto |
|---|
| | | */ |
|---|
| | | public static void addMsg(DatabusQueueDataDto databusQueueDataDto) throws Exception { |
|---|
| | | msgs.offer(databusQueueDataDto, 3, TimeUnit.MILLISECONDS); |
|---|
| | | msgs.offer(databusQueueDataDto, 3, TimeUnit.SECONDS); |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | public static DatabusQueueDataDto getData() throws Exception { |
|---|
| | | |
|---|
| | | return msgs.take(); |
|---|
| | | |
|---|
| | | } |
|---|
