diff --git a/src/main/java/ru/nbch/credit_tracker/service/MonitoringService.java b/src/main/java/ru/nbch/credit_tracker/service/MonitoringService.java index cb1b905..f82e8c7 100644 --- a/src/main/java/ru/nbch/credit_tracker/service/MonitoringService.java +++ b/src/main/java/ru/nbch/credit_tracker/service/MonitoringService.java @@ -37,6 +37,7 @@ public class MonitoringService { private final SignalService signalService; private final IXmlProcessor xmlProcessor; private final CreditTrackerSettings config; + private final Integer batchSize = 10000; public MonitoringService(SignalRestService signalRestService, SignalService signalService, @@ -192,7 +193,10 @@ public class MonitoringService { hits.add(hit); }); }); - signalService.insertHits(hits); + for (int i = 0; i < hits.size(); i += batchSize) { + int end = Math.min(i + batchSize, hits.size()); + signalService.insertHits(hits.subList(i, end)); + } log.info("Signal hits updated for package {}", userPackage.getPackageName()); }