liquanyu / regional-platform

Download as
Browse Code ยป

Commit 9a338c2064d96ab0ec158f52886f9fb77ce84817

Authored by liquanyu
1 parent 89ea3c4bd2
Exists in master and in 1 other branch dev

update code

Showing 1 changed file with 3 additions and 1 deletions

platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java View file @ 9a338c2
... ... @@ -51,7 +51,7 @@
51 51 request.setSql(Base64.encodeBase64String(sql.getBytes()));
52 52 request.setSqlId(sqlId);
53 53 syncSqlQueue.add(request);
54   - System.out.println("syncSqlQueue size = " + syncSqlQueue.size());
  54 + System.out.println("syncSqlQueue size = " + syncSqlQueue.size());
55 55 }
56 56  
57 57 /**
58 58  
... ... @@ -77,7 +77,9 @@
77 77 SqlRequest request = null;
78 78 while (true) {
79 79 try {
  80 + Thread.sleep(3000);
80 81 request = syncSqlQueue.poll();
  82 + System.out.println(request);
81 83 String json = JsonUtil.obj2Str(request);
82 84 if (CollectionUtils.isNotEmpty(urls))
83 85 {