Commit 3fada8a2 authored by 年畅's avatar 年畅 🛀

fix

parent e8da7cd0
......@@ -1273,7 +1273,7 @@ public class OrderRoutingServiceImpl implements OrderRoutingService, Initializin
for (Order order : esList) {
messageList.add(buildMessage(order));
}
List<List<BatchSyncEsMessage>> partition = Lists.partition(messageList, 20);
List<List<BatchSyncEsMessage>> partition = Lists.partition(messageList, 50);
for (List<BatchSyncEsMessage> batchSyncEsMessages : partition) {
messageManager.sendBatchSyncMessageNewOrder(batchSyncEsMessages);
Thread.sleep(millis);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment