treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

http://jira.mfd.msk:8088/browse/CLS-290 SDF56_PROCESS -> REVISE_PROCESS

Browse source
This commit is contained in:
ialbert 2023-05-23 18:14:00 +03:00
parent 41cdca1e3b
commit 4bbd7d09c1
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/BalanceRevise.java
View file

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