diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/EventsReceiver.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/EventsReceiver.java index 989a0caff..6e7647e5c 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/EventsReceiver.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/EventsReceiver.java @@ -73,9 +73,9 @@ public class EventsReceiver extends QueueConsumer implements InitializingBean { callback(LauncherCommandRequest.class) .setConsumer(event -> clearingService.sdfCreate()) .forDestination(Task.createOrder.topic(), callbacks::put); - callback(LauncherCommandRequest.class) - .setConsumer(event -> clearingService.executeVerification()) - .forDestination(Task.getVerification.topic(), callbacks::put); +// callback(LauncherCommandRequest.class) +// .setConsumer(event -> clearingService.executeVerification()) +// .forDestination(Task.getVerification.topic(), callbacks::put); callback(CommonIdRequest.class) .setConsumer(clearingService::continueClearing) .forDestination(Consts.CONTINUE_CLEARING, callbacks::put); @@ -119,6 +119,12 @@ public class EventsReceiver extends QueueConsumer implements InitializingBean { balanceRevise.submit(new ru.spcex.clearing.session.stage.Task<>(TaskType.StartRevise, null)); }) .forDestination(Task.getAllBalance.topic(), callbacks::put); + + callback(LauncherCommandRequest.class) + .setConsumer(task -> { + balanceRevise.submit(new ru.spcex.clearing.session.stage.Task<>(TaskType.StartRevise, null)); + }) + .forDestination(Task.getVerification.topic(), callbacks::put); init(); } }