cheng
2024-01-28 31016f01ec27432295e77d1720b19cd5fd37ce72
product-server-data-center/src/main/java/com/product/data/center/service/DataArchivingQueue.java
@@ -325,8 +325,12 @@
               }
            }
         }
         queryQueue.add(dte);
         WriteUtil.append("DA-成功放入队列-" + tableName + "-当前剩余队列数:" + queryQueue.size());
            while (queryQueue.size() >= 10) {
                SpringMVCContextHolder.getSystemLogger().error("DA-队列已满-" + tableName + "-当前剩余队列数:" + queryQueue.size());
            }
      }
   }