Package com.persequor.saga.modules.crptuzbek.subscription

Class AggregationSubscription

java.lang.Object

com.persequor.saga.modules.compliance.subscription.ComplianceSubscriptionProcessor

com.persequor.saga.modules.compliance.subscription.ResponseBasedComplianceSubscription

com.persequor.saga.modules.crptuzbek.subscription.AggregationSubscription

All Implemented Interfaces:

com.persequor.extension.subscription.IAdvancedSubscriptionProcessor, com.persequor.extension.subscription.ISubscriptionExtension, com.persequor.extension.subscription.ISubscriptionProcessor, com.persequor.saga.modules.compliance.subscription.IComplianceSubscription

public class AggregationSubscription
extends com.persequor.saga.modules.compliance.subscription.ResponseBasedComplianceSubscription

Field Summary

Fields inherited from class com.persequor.saga.modules.compliance.subscription.ComplianceSubscriptionProcessor

ADDITIONAL_DATA_CUSTOM_PROCESSING, ADDITIONAL_DATA_PREFIX, complianceResponseFactory

Constructor Summary

Constructors

Constructor

Description

AggregationSubscription(LoggingCrptUzbekConnector crptConnector, ICrptUzbekOrderMetadataService metadataService, javax.inject.Provider<CrptUzbekComplianceStatusResponse> crptComplianceResponseProvider, javax.inject.Provider<CrptUzbekDetails> crptDetailsProvider, CrptUzbekComplianceRepositoryInfo complianceRepositoryInfo, com.persequor.saga.modules.compliance.services.ComplianceDependencyChecker dependencyChecker, CrptUzbekSubscriptionProcessorSelector processorSelector, ComplianceSubscriptionInfoHelper complianceInfoHelper)

Method Summary

Modifier and Type	Method	Description
boolean	accept(com.persequor.event.Event event)
String	getComplianceRepositoryId()
CrptUzbekReportType	getMessageType()
com.persequor.saga.modules.compliance.subscription.response.ComplianceProcessResponse	processEvent(com.persequor.event.Event event)

Methods inherited from class com.persequor.saga.modules.compliance.subscription.ResponseBasedComplianceSubscription

getProcessingOption, processSingle

Methods inherited from class com.persequor.saga.modules.compliance.subscription.ComplianceSubscriptionProcessor

injectComplianceSubscriptionProcessor, preProcessingHook, process, process, store

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.persequor.saga.modules.compliance.subscription.IComplianceSubscription

afterStorageHook, postProcessingHook

Constructor Details

AggregationSubscription

@Inject
public AggregationSubscription(LoggingCrptUzbekConnector crptConnector,
 ICrptUzbekOrderMetadataService metadataService,
 javax.inject.Provider<CrptUzbekComplianceStatusResponse> crptComplianceResponseProvider,
 javax.inject.Provider<CrptUzbekDetails> crptDetailsProvider,
 CrptUzbekComplianceRepositoryInfo complianceRepositoryInfo,
 com.persequor.saga.modules.compliance.services.ComplianceDependencyChecker dependencyChecker,
 CrptUzbekSubscriptionProcessorSelector processorSelector,
 ComplianceSubscriptionInfoHelper complianceInfoHelper)

Method Details

accept

public boolean accept(com.persequor.event.Event event)

processEvent

public com.persequor.saga.modules.compliance.subscription.response.ComplianceProcessResponse processEvent(com.persequor.event.Event event)

Specified by:

processEvent in class com.persequor.saga.modules.compliance.subscription.ResponseBasedComplianceSubscription

getComplianceRepositoryId

public String getComplianceRepositoryId()

getMessageType

public CrptUzbekReportType getMessageType()