diff --git a/clearing-parent/registry-service/src/main/java/ru/spcex/clearing/registry/service/ExecutionRegisterService.java b/clearing-parent/registry-service/src/main/java/ru/spcex/clearing/registry/service/ExecutionRegisterService.java index 09335a330..893f2e3e7 100644 --- a/clearing-parent/registry-service/src/main/java/ru/spcex/clearing/registry/service/ExecutionRegisterService.java +++ b/clearing-parent/registry-service/src/main/java/ru/spcex/clearing/registry/service/ExecutionRegisterService.java @@ -30,6 +30,7 @@ import java.util.Optional; import static ru.spcex.clearing.imdg.IMDGDistributedNames.*; 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; @Service @@ -59,7 +60,7 @@ public class ExecutionRegisterService extends QueueConsumer implements Initializ public void afterPropertiesSet() { callback(LauncherCommandRequest.class) .setConsumer(this::executionRegisterNew) - .forDestination(createRegistry_LBSR.topic(), callbacks::put); + .forDestination(createRegistry_ECNR.topic(), callbacks::put); init(); }