diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionBnSession.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionBnSession.java index 71b24b379..68f3730bb 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionBnSession.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionBnSession.java @@ -77,10 +77,13 @@ public class PrimaryAuctionBnSession extends QueueConsumer implements Initializi callback(Object.class) .setConsumer(this::continueSession) .forDestination(Consts.SDF57_PROCESS, callbacks::put); + callback(Object.class) + .setConsumer(this::runSession) + .forDestination(ru.spcex.platform.enumeration.Task.startOfClearing.topic(), callbacks::put); init(); } - public void runSession() { + public void runSession(BaseRequest req) { if (!startSession()) { return; }