diff --git a/clearing-parent/utility-service/src/main/java/ru/spcex/clearing/utility/service/AmatAmafChecker.java b/clearing-parent/utility-service/src/main/java/ru/spcex/clearing/utility/service/AmatAmafChecker.java index 2c59775ab..9f38f7fbd 100644 --- a/clearing-parent/utility-service/src/main/java/ru/spcex/clearing/utility/service/AmatAmafChecker.java +++ b/clearing-parent/utility-service/src/main/java/ru/spcex/clearing/utility/service/AmatAmafChecker.java @@ -100,6 +100,7 @@ public class AmatAmafChecker extends QueueConsumer implements InitializingBean { } else { log.debug("Selecting {} AM_T and by tradingClearingRegistry and securitySymbol AM_F for his.", specialId); long timer = System.currentTimeMillis(); + specialId = specialId.stream().distinct().collect(Collectors.toList()); // deduplicate checkRegistries = new ArrayList<>(specialId.size() * 2); for (Long am_tId : specialId) { if (am_tId == null) { // never