diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java index 4e39779..4e1b514 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java @@ -78,7 +78,7 @@ public class SendMysqlSyncDatUtil implements InitializingBean { while (true) { try { Thread.sleep(3000); - request = syncSqlQueue.poll(); + request = syncSqlQueue.take(); System.out.println(request); String json = JsonUtil.obj2Str(request); if (CollectionUtils.isNotEmpty(urls))