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

http://jira.mfd.msk:8088/browse/CLS-280

Browse source 
---
fix up
This commit is contained in:
aalehin 2023-06-02 15:32:57 +03:00
parent 6536852791
commit 21d959740f
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
clearing-parent/registry-service/src/main/java/ru/spcex/clearing/registry/service/ExecutionRegisterService.java
View file

@ -30,6 +30,7 @@ import java.util.Optional;
import static ru.spcex.clearing.imdg.IMDGDistributedNames.*; import static ru.spcex.clearing.imdg.IMDGDistributedNames.*;
import static ru.spcex.clearing.registry.util.FieldValuesValidator.getFieldValuesOrThrowException; import static ru.spcex.clearing.registry.util.FieldValuesValidator.getFieldValuesOrThrowException;
import static ru.spcex.platform.enumeration.Task.createRegistry_ECNR;
import static ru.spcex.platform.enumeration.Task.createRegistry_LBSR; import static ru.spcex.platform.enumeration.Task.createRegistry_LBSR;
@Service @Service
@ -59,7 +60,7 @@ public class ExecutionRegisterService extends QueueConsumer implements Initializ
public void afterPropertiesSet() { public void afterPropertiesSet() {
callback(LauncherCommandRequest.class) callback(LauncherCommandRequest.class)
.setConsumer(this::executionRegisterNew) .setConsumer(this::executionRegisterNew)
.forDestination(createRegistry_LBSR.topic(), callbacks::put); .forDestination(createRegistry_ECNR.topic(), callbacks::put);
init(); init();
} }