Class ComplianceSubscriptionExceptionHelper
java.lang.Object
com.persequor.saga.modules.compliance.subscription.ComplianceSubscriptionExceptionHelper
-
Constructor Summary
ConstructorsConstructorDescriptionComplianceSubscriptionExceptionHelper
(ComplianceModuleConfig config, com.persequor.extension.IDelayConfigurationRegistry delayRegistry, LegacyMessageStatusComparator statusImportanceComparator) -
Method Summary
Modifier and TypeMethodDescriptioncom.persequor.extension.subscription.SubscriptionFailedException
buildRetryAttemptsExceededException
(com.persequor.extension.subscription.SubscriptionDelayException delayException, ComplianceServiceReplyList listOfStatuses, com.persequor.event.Event event) computeStatusBasedOnRetries
(ComplianceServiceReplyList replyList, int maxRetries, MessageStatus defaultStatus) Compute the status to be stored, given a maximum number of retries and a list of statuses.getFailReason
(Exception exception) int
getMaxRetries
(com.persequor.extension.subscription.SubscriptionDelayException delayException)
-
Constructor Details
-
ComplianceSubscriptionExceptionHelper
@Inject public ComplianceSubscriptionExceptionHelper(ComplianceModuleConfig config, com.persequor.extension.IDelayConfigurationRegistry delayRegistry, LegacyMessageStatusComparator statusImportanceComparator)
-
-
Method Details
-
buildRetryAttemptsExceededException
public com.persequor.extension.subscription.SubscriptionFailedException buildRetryAttemptsExceededException(com.persequor.extension.subscription.SubscriptionDelayException delayException, ComplianceServiceReplyList listOfStatuses, com.persequor.event.Event event) -
getMaxRetries
public int getMaxRetries(com.persequor.extension.subscription.SubscriptionDelayException delayException) -
computeStatusBasedOnRetries
public MessageStatus computeStatusBasedOnRetries(ComplianceServiceReplyList replyList, int maxRetries, MessageStatus defaultStatus) Compute the status to be stored, given a maximum number of retries and a list of statuses.- Parameters:
replyList
- The replies for the event in the given compliance repositorymaxRetries
- the maximum number of retriesdefaultStatus
- the status to persist if the number of tries is lower to the maximum passed in- Returns:
- defaultStatus if the maximum number of tries is not reached, otherwise MessageStatus.RETRY_ATTEMPT_EXCEEDED
-
getFailReason
-