From 08340829887aa1f36956e5f8f90caebb3a299a10 Mon Sep 17 00:00:00 2001 From: ialbert Date: Wed, 25 Jun 2025 16:15:21 +0300 Subject: [PATCH] state session continue test --- .../main/java/ru/spcex/clearing/service/EventsReceiver.java | 3 +++ 1 file changed, 3 insertions(+) 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 f3c6c13f5..cb7500494 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 @@ -162,6 +162,9 @@ public class EventsReceiver extends QueueConsumerV2 implements InitializingBean return null; }) .forDestination(Task.startOfClearing.topic(), callbacks::put); + callback(Object.class) + .setConsumer(o -> stateMachineWrapper.sendEvent(SsnEvent.CONTINUE)) + .forDestination("continue-state-session", callbacks::put); callback(PIClearingOutbondActionNewRequest.class) .setFunction(pmtOutboundService::sendOutBoundPayment)