优化小区数据

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;
@@ -20,10 +21,10 @@
     */
    public static void addMsg(DatabusQueueDataDto databusQueueDataDto) throws Exception {
        msgs.offer(databusQueueDataDto, 3, TimeUnit.SECONDS);

    }

    public static DatabusQueueDataDto getData() throws Exception {

        return msgs.take();

    }