Package com.broadleafcommerce.deadletter.service.impl

Class DefaultDeadLetterService<P extends DeadLetter>

java.lang.Object

com.broadleafcommerce.data.tracking.core.service.BaseCrudEntityService<P>

com.broadleafcommerce.data.tracking.core.service.BaseRsqlCrudEntityService<P>

com.broadleafcommerce.deadletter.service.impl.DefaultDeadLetterService<P>

All Implemented Interfaces:

com.broadleafcommerce.data.tracking.core.service.CrudEntityService<P>, com.broadleafcommerce.data.tracking.core.service.RsqlCrudEntityService<P>, DeadLetterService<P>

public class DefaultDeadLetterService<P extends DeadLetter>
extends com.broadleafcommerce.data.tracking.core.service.BaseRsqlCrudEntityService<P>
implements DeadLetterService<P>

Field Summary

Fields

Modifier and Type	Field	Description
protected DeadLetterProperties	properties
protected List<DeadLetterRetryHandler<P>>	retryHandlers

Constructor Summary

Constructors

Constructor	Description
DefaultDeadLetterService(DeadLetterRepository<com.broadleafcommerce.data.tracking.core.Trackable> repository, com.broadleafcommerce.data.tracking.core.service.RsqlCrudEntityHelper helper)

Method Summary

Modifier and Type	Method	Description
boolean	canHandleRetry(P deadLetter)	Detect if there are any valid handlers available to re-engage the processing flow with a previous failed message.
Long	countOfDeadLetterByStatus(DeadLetterResolutionStatusEnum resolutionStatus, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
protected List<P>	findDeadLettersByDateRangeAndStatus(DeadLetterQueueNotificationRequest request, DeadLetterResolutionStatusEnum resolutionStatus, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Deprecated.
protected List<P>	findDeadLettersByEndDateAndStatus(DeadLetterQueueNotificationRequest request, DeadLetterResolutionStatusEnum resolutionStatus, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Deprecated.
protected List<P>	findDeadLettersByStartDateAndStatus(DeadLetterQueueNotificationRequest request, DeadLetterResolutionStatusEnum resolutionStatus, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Deprecated.
protected List<P>	findDeadLettersByStatus(DeadLetterQueueNotificationRequest request, DeadLetterResolutionStatusEnum resolutionStatus, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Deprecated.
protected int	getNumberOfDeadLettersToRender(DeadLetterQueueNotificationRequest request)
List<P>	readUnresolvedDeadLetters(DeadLetterQueueNotificationRequest request, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Deprecated. Generally preferable to use BaseRsqlCrudEntityService.readAll(Node, Pageable, ContextInfo)
void	retry(P deadLetter, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Attempt to re-engage the processing flow with a previous failed message that did not allow the process to complete.

Methods inherited from class com.broadleafcommerce.data.tracking.core.service.BaseRsqlCrudEntityService

getRsqlHelper, readAll, readAll, readAll, readAll

Methods inherited from class com.broadleafcommerce.data.tracking.core.service.BaseCrudEntityService

convertFromPersistentDomain, convertToPersistentDomain, create, createAll, createAllAllowingPartialSuccess, delete, getHelper, getRepository, getSortPositionStrategy, readAll, readAll, readAll, readAllByContextId, readByContextId, replace, replaceAll, replaceAllAllowingPartialSuccess, setSortPositionStrategy, update, updateAll, updateAllAllowingPartialSuccess, updateSort

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.broadleafcommerce.data.tracking.core.service.CrudEntityService

create, createAll, createAllAllowingPartialSuccess, delete, readAll, readAll, readAll, readAllByContextId, readByContextId, replace, replaceAll, replaceAllAllowingPartialSuccess, update, updateAll, updateAllAllowingPartialSuccess, updateSort

Methods inherited from interface com.broadleafcommerce.deadletter.service.DeadLetterService

countOfDeadLetterByStatus, findUnresolvedDeadLetters, save

Methods inherited from interface com.broadleafcommerce.data.tracking.core.service.RsqlCrudEntityService

readAll, readAll, readAll, readAll

Field Details

properties

@Autowired
protected DeadLetterProperties properties

retryHandlers

@Autowired
protected List<DeadLetterRetryHandler<P extends DeadLetter>> retryHandlers

Constructor Details

DefaultDeadLetterService

public DefaultDeadLetterService(DeadLetterRepository<com.broadleafcommerce.data.tracking.core.Trackable> repository,
 com.broadleafcommerce.data.tracking.core.service.RsqlCrudEntityHelper helper)

Method Details

canHandleRetry

public boolean canHandleRetry(P deadLetter)

Description copied from interface: DeadLetterService

Detect if there are any valid handlers available to re-engage the processing flow with a previous failed message.

Specified by:

canHandleRetry in interface DeadLetterService<P extends DeadLetter>

retry

public void retry(P deadLetter,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: DeadLetterService

Attempt to re-engage the processing flow with a previous failed message that did not allow the process to complete.

Specified by:

retry in interface DeadLetterService<P extends DeadLetter>

readUnresolvedDeadLetters

@Deprecated(since="1.0.0")
public List<P> readUnresolvedDeadLetters(DeadLetterQueueNotificationRequest request,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Deprecated.

Generally preferable to use BaseRsqlCrudEntityService.readAll(Node, Pageable, ContextInfo)

Specified by:

readUnresolvedDeadLetters in interface DeadLetterService<P extends DeadLetter>

findDeadLettersByDateRangeAndStatus

@Deprecated(since="1.0.0")
protected List<P> findDeadLettersByDateRangeAndStatus(DeadLetterQueueNotificationRequest request,
 DeadLetterResolutionStatusEnum resolutionStatus,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Deprecated.

findDeadLettersByStartDateAndStatus

@Deprecated(since="1.0.0")
protected List<P> findDeadLettersByStartDateAndStatus(DeadLetterQueueNotificationRequest request,
 DeadLetterResolutionStatusEnum resolutionStatus,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Deprecated.

findDeadLettersByEndDateAndStatus

@Deprecated(since="1.0.0")
protected List<P> findDeadLettersByEndDateAndStatus(DeadLetterQueueNotificationRequest request,
 DeadLetterResolutionStatusEnum resolutionStatus,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Deprecated.

findDeadLettersByStatus

@Deprecated(since="1.0.0")
protected List<P> findDeadLettersByStatus(DeadLetterQueueNotificationRequest request,
 DeadLetterResolutionStatusEnum resolutionStatus,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Deprecated.

countOfDeadLetterByStatus

public Long countOfDeadLetterByStatus(DeadLetterResolutionStatusEnum resolutionStatus,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Specified by:

countOfDeadLetterByStatus in interface DeadLetterService<P extends DeadLetter>

getNumberOfDeadLettersToRender

protected int getNumberOfDeadLettersToRender(DeadLetterQueueNotificationRequest request)