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

http://jira.mfd.msk:8088/browse/CLS-290 removed consumer from PrimaryAuctionBnSession.java

Browse source
This commit is contained in:
ialbert 2023-05-23 18:00:55 +03:00
parent 10c0d8790c
commit 32bcede266
1 changed files with 1 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/PrimaryAuctionBnSession.java
View file

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