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

state session continue test

Browse source
This commit is contained in:
ialbert 2025-06-25 16:15:21 +03:00
parent 07e096cf76
commit 0834082988
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -162,6 +162,9 @@ public class EventsReceiver extends QueueConsumerV2 implements InitializingBean
return null; return null;
}) })
.forDestination(Task.startOfClearing.topic(), callbacks::put); .forDestination(Task.startOfClearing.topic(), callbacks::put);
callback(Object.class)
.setConsumer(o -> stateMachineWrapper.sendEvent(SsnEvent.CONTINUE))
.forDestination("continue-state-session", callbacks::put);
callback(PIClearingOutbondActionNewRequest.class) callback(PIClearingOutbondActionNewRequest.class)
.setFunction(pmtOutboundService::sendOutBoundPayment) .setFunction(pmtOutboundService::sendOutBoundPayment)