diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/ClearingService.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/ClearingService.java index 66f61dfa0..50cf5d56f 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/ClearingService.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/ClearingService.java @@ -23,16 +23,19 @@ public class ClearingService implements DisposableBean { private final VerificationResultComponent verificationResultComponent; private final Clearing clearing; private final ExecutionDepositComponent executionDepositComponent; + private final ExecutionFondComponent executionFondComponent; @Autowired public ClearingService(SdfCreatorBySTLDPayment sdfCreator, PaymentUpdateBySdf04 paymentUpdater, VerificationResultComponent verificationResultComponent, Clearing clearing, - ExecutionDepositComponent executionDepositComponent) { + ExecutionDepositComponent executionDepositComponent, + ExecutionFondComponent executionFondComponent) { this.sdfCreator = sdfCreator; this.paymentUpdater = paymentUpdater; this.verificationResultComponent = verificationResultComponent; this.executionDepositComponent = executionDepositComponent; this.clearing = clearing; + this.executionFondComponent = executionFondComponent; this.executor = Executors.newSingleThreadExecutor(); } @@ -101,6 +104,7 @@ public class ClearingService implements DisposableBean { executor.execute(() -> { try { executionDepositComponent.processNewTS(); + executionFondComponent.processNewTS(); } catch (Throwable e) { log.error("{}", ExceptionUtils.getStackTrace(e)); }