From 32bcede2663b9e0bbcfc873f26be09f6c982ec91 Mon Sep 17 00:00:00 2001
From: ialbert <ialbert@mfd.ru>
Date: Tue, 23 May 2023 18:00:55 +0300
Subject: [PATCH] http://jira.mfd.msk:8088/browse/CLS-290 removed consumer from
 PrimaryAuctionBnSession.java

---
 .../session/stage/PrimaryAuctionBnSession.java      | 13 +------------
 1 file changed, 1 insertion(+), 12 deletions(-)

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 736648dc3..3d7a35f1d 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
@@ -1,16 +1,12 @@
 package ru.spcex.clearing.session.stage;
 
-import org.apache.kafka.clients.consumer.Consumer;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.InitializingBean;
-import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.stereotype.Service;
 import ru.clearing.classes.statics.data.execution.ExecutionCommon;
 import ru.clearing.classes.statics.data.misc.Session;
 import ru.spcex.clearing.imdg.IMDGDistributedNames;
 import ru.spcex.clearing.platform.messaging.domain.BaseRequest;
-import ru.spcex.clearing.platform.messaging.service.QueueConsumer;
 import ru.spcex.clearing.session.stage.impl.*;
 import ru.spcex.clearing.session.stage.task.*;
 import ru.spcex.platform.enumeration.Section;
@@ -24,7 +20,7 @@ import java.util.List;
 import java.util.concurrent.atomic.AtomicReference;
 
 @Service
-public class PrimaryAuctionBnSession extends QueueConsumer implements InitializingBean {
+public class PrimaryAuctionBnSession {
     private final Logger log = LoggerFactory.getLogger(getClass());
     private final BalanceRevise balanceRevise;
     private final DealsPrepare dealsPrepare;
@@ -44,7 +40,6 @@ public class PrimaryAuctionBnSession extends QueueConsumer implements Initializi
     private Session currSession;
 
     public PrimaryAuctionBnSession(
-            @Qualifier("createConsumer") Consumer<String, Object> kafkaQueue,
             ImdgProvider imdgProvider,
             BalanceRevise balanceRevise,
             DealsPrepare dealsPrepare,
@@ -55,7 +50,6 @@ public class PrimaryAuctionBnSession extends QueueConsumer implements Initializi
             FormingPaymentInstruction formingPaymentInstruction,
             UnlockResources unlockResources,
             FinishingSession finishingSession, EndStageNotification endStageNotification, IMessageResolver messageResolver) {
-        super(kafkaQueue);
         this.balanceRevise = balanceRevise;
         this.dealsPrepare = dealsPrepare;
         this.requirementsAndObligationCreation = requirementsAndObligationCreation;
@@ -71,11 +65,6 @@ public class PrimaryAuctionBnSession extends QueueConsumer implements Initializi
         this.messageResolver = messageResolver;
     }
 
-    @Override
-    public void afterPropertiesSet() throws Exception {
-        init();
-    }
-
     public void runSession(BaseRequest<?> req) {
         if (!startSession()) {
             return;