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));