diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/BalanceRevise.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/BalanceRevise.java
index 36baf05c1..6095ab108 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/BalanceRevise.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/BalanceRevise.java
@@ -79,7 +79,7 @@ public class BalanceRevise implements ISessionStage {
         sdf56Request.seteDateTime(now);
         sdf56Request.setDf51Number(idGenerator.nextId()); //fixme day scope id generator
         sdf56Request.setDateTime(now);
-        Long msgKey = kafkaSender.sendRequestToQueue(Consts.SDF56_PROCESS, sdf56Request);
+        Long msgKey = kafkaSender.sendRequestToQueue(Consts.REVISE_PROCESS, sdf56Request);
         if (msgKey == null) {
             log.error("failed to put SDF56 request to kafka queue");
             return new StageResult<>(new EnumMessage(SessionGeneralError), false);