From cd35d5ba9c538f89a66dd524b8c3c759013371cc Mon Sep 17 00:00:00 2001 From: ialbert Date: Wed, 28 Jun 2023 10:13:30 +0300 Subject: [PATCH] =?UTF-8?q?GVER=20=D1=82=D0=B5=D0=BF=D0=B5=D1=80=D1=8C=20?= =?UTF-8?q?=D0=B7=D0=B0=D0=BF=D1=83=D1=81=D0=BA=D0=B0=D0=B5=D1=82=20=D1=81?= =?UTF-8?q?=D0=B2=D0=B5=D1=80=D0=BA=D1=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ru/spcex/clearing/service/EventsReceiver.java | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) 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(); } }