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 abee9dbcc..989a0caff 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
@@ -17,6 +17,7 @@ import ru.spcex.clearing.platform.messaging.domain.cud.utilities.STradesImported
 import ru.spcex.clearing.platform.messaging.service.QueueConsumer;
 import ru.spcex.clearing.service.executors.Sdf06Executor;
 import ru.spcex.clearing.session.stage.*;
+import ru.spcex.clearing.session.stage.impl.BalanceRevise;
 import ru.spcex.platform.enumeration.Task;
 
 import static ru.spcex.clearing.platform.messaging.domain.Consts.S_TRADES_IMPORTED;
@@ -35,6 +36,7 @@ public class EventsReceiver extends QueueConsumer implements InitializingBean {
     private final ReturnDepositSession returnDepositSession;
     private final SessionManager sessionManager;
     private final Sdf06Executor sdf06Executor;
+    private final BalanceRevise balanceRevise;
 
     @Autowired
     public EventsReceiver(Consumer<String, Object> kafkaQueue,
@@ -43,7 +45,8 @@ public class EventsReceiver extends QueueConsumer implements InitializingBean {
                           PrimaryAuctionBnSession primaryAuctionBnSession,
                           SecondaryAuctionT0Session secondaryAuctionT0Session,
                           PrimaryAuctionB0Session primaryAuctionB0Session, PrimaryAuctionT0Session primaryAuctionT0Session, IntermediateMkrSession intermediateMkrSession, FinalMkrSession finalMkrSession, ReturnDepositSession returnDepositSession, SessionManager sessionManager,
-                          Sdf06Executor sdf06Executor) {
+                          Sdf06Executor sdf06Executor,
+                          BalanceRevise balanceRevise) {
         super(kafkaQueue);
         this.clearingService = clearingService;
         this.registryService = registryService;
@@ -56,6 +59,7 @@ public class EventsReceiver extends QueueConsumer implements InitializingBean {
         this.returnDepositSession = returnDepositSession;
         this.sessionManager = sessionManager;
         this.sdf06Executor = sdf06Executor;
+        this.balanceRevise = balanceRevise;
     }
 
     @Override
@@ -109,6 +113,12 @@ public class EventsReceiver extends QueueConsumer implements InitializingBean {
         callback(LauncherCommandRequest.class)
                 .setConsumer(event -> registryService.resetBalances())
                 .forDestination(Task.createRegistry_GRYT.topic(), callbacks::put);
+
+        callback(LauncherCommandRequest.class)
+                .setConsumer(task -> {
+                    balanceRevise.submit(new ru.spcex.clearing.session.stage.Task<>(TaskType.StartRevise, null));
+                })
+                .forDestination(Task.getAllBalance.topic(), callbacks::put);
         init();
     }
 }