优化代码

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

@@ -19,7 +19,7 @@ public class DatabusDataQueue {
      * @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 {

service-job/src/main/java/com/java110/job/export/ExportDataQueue.java

@@ -21,7 +21,7 @@ public class ExportDataQueue {
     public static void addMsg(ExportDataDto exportDataDto) {
         try {
 
-            msgs.offer(exportDataDto,3, TimeUnit.MILLISECONDS);
+            msgs.offer(exportDataDto,3, TimeUnit.SECONDS);
         } catch (Exception e) {
             log.error("写入队列失败", e);
             e.printStackTrace();

service-job/src/main/java/com/java110/job/importData/ImportDataQueue.java

@@ -22,7 +22,7 @@ public class ImportDataQueue {
     public static void addMsg(ImportDataDto importDataDto) {
         try {
 
-            msgs.offer(importDataDto, 3, TimeUnit.MILLISECONDS);
+            msgs.offer(importDataDto, 3, TimeUnit.SECONDS);
         } catch (Exception e) {
             log.error("写入队列失败", e);
             e.printStackTrace();