diff --git a/clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/service/DigitalSecurityService.java b/clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/service/DigitalSecurityService.java index 95c931835..3f8e3bf96 100644 --- a/clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/service/DigitalSecurityService.java +++ b/clearing-parent/gateway-api/src/main/java/ru/spcex/clearing/gatewayapi/service/DigitalSecurityService.java @@ -46,8 +46,9 @@ public class DigitalSecurityService { for (DigitalCertificate security : securityList) { try { DigitalCertificateSecurityGatewayRequest digitalCertificateSecurityRequest = digitalSecurityRequestAdapter.toRequest(security); - List listingRequests = request.getListingList().stream(). - map(securityRequestAdapter::toIncomeListing).toList(); + List listingRequests = request.getListingList().stream() + .filter(incomeListing -> incomeListing.getSymbolCode().equals(security.getSecuritySymbol())) + .map(securityRequestAdapter::toIncomeListing).toList(); digitalCertificateSecurityRequest.setListing(listingRequests); kafkaSender.sendRequestToQueue(Consts.DESTINATION_SECURITY_DGCT_GATEWAY, digitalCertificateSecurityRequest); } catch (Throwable e) {