Package com.persequor.saga.modules.compliance.subscription

Class ComplianceSubscription

java.lang.Object

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

com.persequor.saga.modules.compliance.subscription.ComplianceSubscription

All Implemented Interfaces:

com.persequor.extension.subscription.IAdvancedSubscriptionProcessor, com.persequor.extension.subscription.ISubscriptionExtension, com.persequor.extension.subscription.ISubscriptionProcessor, IComplianceSubscription

@Deprecated
public abstract class ComplianceSubscription
extends ComplianceSubscriptionProcessor

Deprecated.

use ResponseBasedComplianceSubscription instead

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
ComplianceSubscription()	Deprecated.

Method Summary

Modifier and Type	Method	Description
final com.persequor.extension.subscription.ProcessingMode	getProcessingOption()	Deprecated. The overarching
protected abstract ComplianceRepositoryReplyList	processEvent(com.persequor.event.Event event)	Deprecated.
final ComplianceProcessResponse	processSingle(com.persequor.event.Event event)	Deprecated. Here your subscription processes the event.

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, getComplianceRepositoryId, getMessageType, postProcessingHook

Methods inherited from interface com.persequor.extension.subscription.ISubscriptionExtension

accept

Constructor Details

ComplianceSubscription

public ComplianceSubscription()

Deprecated.

Method Details

getProcessingOption

public final com.persequor.extension.subscription.ProcessingMode getProcessingOption()

Deprecated.

The overarching

Returns:

ProcessingMode.Individual

processSingle

public final ComplianceProcessResponse processSingle(com.persequor.event.Event event)

Deprecated.

Description copied from interface: IComplianceSubscription

Here your subscription processes the event. This method is called asynchronously.

Use the ComplianceResponseFactory to construct the wanted response. Here are the types of responses currently supported :

- Should the event not be ready yet (other data is missing) you can push the event back for later processing by returning a RetryComplianceResponse having its action being 'RETRY'.

- Returning a FailComplianceResponse will place the event(s) in issues. Here an operator must manually push them back into the subscription queue, or delete them in which case they never get processed by this subscription.

- Returning a BasicComplianceResponse will store the reply provided with the response.

- Returning a NotApplicableComplianceResponse will store a NOT_APPLICABLE status. If a reply is provided with the response, the statusReason will be picked up.

- Returning null is also allowed, in which case nothing will happen.

Returns:

The response generated from the result of submitting the event to the compliance repository along with the action to be taken

processEvent

protected abstract ComplianceRepositoryReplyList processEvent(com.persequor.event.Event event)
                                                       throws com.persequor.extension.subscription.SubscriptionDelayException,
com.persequor.extension.subscription.SubscriptionFailedException

Deprecated.

Throws:

com.persequor.extension.subscription.SubscriptionDelayException

com.persequor.extension.subscription.SubscriptionFailedException