Package com.broadleafcommerce.catalog.messaging.bulkoperation

Class PurgeBulkOperationHandler

java.lang.Object

com.broadleafcommerce.catalog.messaging.bulkoperation.PurgeBulkOperationHandler

@DataRouteByKey("catalog")
public class PurgeBulkOperationHandler
extends Object

Author:

Nathan Moore (nathandmoore)

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	DEFAULT_PURGE_BATCH_SIZE
protected static final String	DEFAULT_PURGE_ITEM_BATCH_SIZE
protected static final Set<String>	DEFAULT_PURGE_STATUSES
protected static final String	DEFAULT_PURGE_THRESHOLD
static final String	DETAIL_KEY_PURGE_BATCH_SIZE
static final String	DETAIL_KEY_PURGE_ITEM_BATCH_SIZE
static final String	DETAIL_KEY_PURGE_OPERATION_STATUSES
static final String	DETAIL_KEY_PURGE_THRESHOLD
protected static final DateTimeFormatter	FORMATTER
static final String	JOB_NAME

Constructor Summary

Constructors

Constructor	Description
PurgeBulkOperationHandler(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentMessageService, BulkOperationService<BulkOperation> bulkOperationService, BulkOperationItemService<BulkOperationItem> bulkOperationItemService)

Method Summary

Modifier and Type	Method	Description
protected Map<String,String>	buildJobDetailsMap(com.broadleafcommerce.common.messaging.domain.ScheduledJobRef job)	Build a map from the scheduled job details.
protected void	deleteBatch(Collection<String> bulkIds, Map<String,String> jobDetails)
protected void	doHandleEvent(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)
protected BulkOperationItemService<BulkOperationItem>	getBulkOperationItemService()
protected BulkOperationService<BulkOperation>	getBulkOperationService()
protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService	getIdempotentMessageService()
protected int	getPurgeBatchSize(Map<String,String> jobDetails)
protected int	getPurgeItemBatchSize(Map<String,String> jobDetails)
protected Set<String>	getPurgeOperationStatuses(Map<String,String> jobDetails)
protected Instant	getPurgeThreshold(Map<String,String> jobDetails)
protected void	handle(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)	Handles deleting all the BulkOperations and their BulkOperationItems that are older than the configured age threshold.
void	listen(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)
protected void	processBulkOperationDeletion(Collection<String> bulkIds)
protected Integer	processIndividualBulkItemDeletion(List<String> itemIds)
protected void	processItemCompletionDeletion(Collection<String> bulkOpsIds, int batchSize)
protected List<String>	readBulkItemIdsForBatch(Collection<String> bulkOpsIds, int batchSize)
protected List<BulkOperation>	readBulkOperationsToDelete(Map<String,String> jobDetails)

Methods inherited from class java.lang.Object

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

Field Details

JOB_NAME

public static final String JOB_NAME

See Also:

• Constant Field Values

DETAIL_KEY_PURGE_THRESHOLD

public static final String DETAIL_KEY_PURGE_THRESHOLD

See Also:

• Constant Field Values

DETAIL_KEY_PURGE_BATCH_SIZE

public static final String DETAIL_KEY_PURGE_BATCH_SIZE

See Also:

• Constant Field Values

DETAIL_KEY_PURGE_ITEM_BATCH_SIZE

public static final String DETAIL_KEY_PURGE_ITEM_BATCH_SIZE

See Also:

• Constant Field Values

DETAIL_KEY_PURGE_OPERATION_STATUSES

public static final String DETAIL_KEY_PURGE_OPERATION_STATUSES

See Also:

• Constant Field Values

DEFAULT_PURGE_THRESHOLD

protected static final String DEFAULT_PURGE_THRESHOLD

See Also:

• Constant Field Values

DEFAULT_PURGE_BATCH_SIZE

protected static final String DEFAULT_PURGE_BATCH_SIZE

See Also:

• Constant Field Values

DEFAULT_PURGE_ITEM_BATCH_SIZE

protected static final String DEFAULT_PURGE_ITEM_BATCH_SIZE

See Also:

• Constant Field Values

DEFAULT_PURGE_STATUSES

protected static final Set<String> DEFAULT_PURGE_STATUSES

FORMATTER

protected static final DateTimeFormatter FORMATTER

Constructor Details

PurgeBulkOperationHandler

public PurgeBulkOperationHandler(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentMessageService,
 BulkOperationService<BulkOperation> bulkOperationService,
 BulkOperationItemService<BulkOperationItem> bulkOperationItemService)

Method Details

listen

@StreamListener("triggeredJobEventInputPurgeBulkOperation")
public void listen(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)

doHandleEvent

protected void doHandleEvent(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)

handle

protected void handle(org.springframework.messaging.Message<com.broadleafcommerce.common.messaging.domain.ScheduledJobRef> message)

Handles deleting all the BulkOperations and their BulkOperationItems that are older than the configured age threshold.

Parameters:

message - The received message with the ScheduledJobRef.

readBulkOperationsToDelete

protected List<BulkOperation> readBulkOperationsToDelete(Map<String,String> jobDetails)

deleteBatch

protected void deleteBatch(Collection<String> bulkIds,
 Map<String,String> jobDetails)

processItemCompletionDeletion

protected void processItemCompletionDeletion(Collection<String> bulkOpsIds,
 int batchSize)

processBulkOperationDeletion

protected void processBulkOperationDeletion(Collection<String> bulkIds)

readBulkItemIdsForBatch

protected List<String> readBulkItemIdsForBatch(Collection<String> bulkOpsIds,
 int batchSize)

processIndividualBulkItemDeletion

protected Integer processIndividualBulkItemDeletion(List<String> itemIds)

buildJobDetailsMap

protected Map<String,String> buildJobDetailsMap(com.broadleafcommerce.common.messaging.domain.ScheduledJobRef job)

Build a map from the scheduled job details.

Parameters:

job - The job being executed.

Returns:

Map of ScheduledJobDetailRef name to String value

getPurgeThreshold

protected Instant getPurgeThreshold(Map<String,String> jobDetails)

getPurgeBatchSize

protected int getPurgeBatchSize(Map<String,String> jobDetails)

getPurgeItemBatchSize

protected int getPurgeItemBatchSize(Map<String,String> jobDetails)

getPurgeOperationStatuses

protected Set<String> getPurgeOperationStatuses(Map<String,String> jobDetails)

getIdempotentMessageService

protected com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService getIdempotentMessageService()

getBulkOperationService

protected BulkOperationService<BulkOperation> getBulkOperationService()

getBulkOperationItemService

protected BulkOperationItemService<BulkOperationItem> getBulkOperationItemService()