From 4bbd7d09c10e2914381b12989d28edda4fec83e2 Mon Sep 17 00:00:00 2001 From: ialbert Date: Tue, 23 May 2023 18:14:00 +0300 Subject: [PATCH] http://jira.mfd.msk:8088/browse/CLS-290 SDF56_PROCESS -> REVISE_PROCESS --- .../ru/spcex/clearing/session/stage/impl/BalanceRevise.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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);