From c5f80b8aca56ce5f89ff489ee7508eb4f9019dd7 Mon Sep 17 00:00:00 2001 From: liquanyu Date: Fri, 19 May 2017 21:46:49 +0800 Subject: [PATCH] update code --- .../java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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)) -- 1.8.3.1