优化小区数据

wuxw

2024-01-22 a40c2eb885bcdb697c2e16dae4f43cb6cd718973

 service-job/src/main/java/com/java110/job/databus/DatabusDataQueue.java

@@ -1,5 +1,6 @@
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;
@@ -18,23 +19,14 @@
     *
     * @param databusQueueDataDto
     */
    public static void addMsg(DatabusQueueDataDto databusQueueDataDto) {
        try {
    public static void addMsg(DatabusQueueDataDto databusQueueDataDto) throws Exception {
        msgs.offer(databusQueueDataDto, 3, TimeUnit.SECONDS);

            msgs.offer(databusQueueDataDto, 3, TimeUnit.MILLISECONDS);
        } catch (Exception e) {
            log.error("写入队列失败", e);
            e.printStackTrace();
        }
    }

    public static DatabusQueueDataDto getData() {
        try {
            return msgs.take();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return null;
    public static DatabusQueueDataDto getData() throws Exception {
        return msgs.take();

    }

}