From c75a4655c9eba2db44ac8761666e6cd2e26e5858 Mon Sep 17 00:00:00 2001 From: etreschenkov Date: Wed, 22 Apr 2026 18:49:45 +0300 Subject: [PATCH] http://jira.mfd.msk:8088/browse/CLS-943 --- .../clearing/dflt/management/listener/TaskListener.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/TaskListener.java b/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/TaskListener.java index eefc4421b..8b3afb4dd 100644 --- a/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/TaskListener.java +++ b/clearing-parent/default-management/src/main/java/ru/spcex/clearing/dflt/management/listener/TaskListener.java @@ -143,7 +143,7 @@ public class TaskListener extends QueueConsumer implements InitializingBean { newReq.setObjectType(ObjectType.rgst.getKey()); newReq.setPriority(Priority.HIGH.getKey()); newReq.setComment(comment); - kafkaSender.sendRequestToQueue(Consts.NOTIFICATION_NEW, req.getRequestPayload()); + kafkaSender.sendRequestToQueue(Consts.NOTIFICATION_NEW, newReq); log.info("SDOR export and send command to fix, request={}", req); try { @@ -176,10 +176,6 @@ public class TaskListener extends QueueConsumer implements InitializingBean { } if (diff.compareTo(BigDecimal.ZERO) < 0) { - NotificationNewRequest request = new NotificationNewRequest(); - request.setObjectType(ObjectType.rgst.getKey()); - request.setPriority(Priority.HIGH.getKey()); - return String.format("Для ТКР %s компании %s: баланс %s RUB;", amtRegistry.getTradingClearingRegistry(), amtRegistry.getShortName(), diff.setScale(2, RoundingMode.HALF_UP));