com.broadleafcommerce.jobsevents.service

Class AbandonedProcessWorkerImpl

java.lang.Object

com.broadleafcommerce.jobsevents.service.AbstractConsumerWorker

com.broadleafcommerce.jobsevents.service.AbandonedProcessWorkerImpl

All Implemented Interfaces:

ConsumeWorker

@Service(value="blAbandonedProcessWorker")
public class AbandonedProcessWorkerImpl
extends AbstractConsumerWorker

This worker is primarily responsible for grooming the database state for ProcessStatus. It will remove ProcessStatus instances from the servers currently active list if they do not exist on the database. It will also archive any abandoned ProcessStatus instances that have not been explicitly associated with an async thread of execution. It will purge any archived ProcessStatus instances that are older than a configurable threshold. Finally, it will update the ProcessStatus.getLastUpdated() time to the current db server time for all active ProcessStatus instances.

Author:

Jeff Fischer

Field Summary

Fields

Modifier and Type	Field and Description
protected int	abandonedHandleThresholdSeconds
protected int	abandonedPurgeThresholdSeconds
protected ScheduledJobManager	jobManager
protected ProcessDao	processDao
protected ProcessManager	processManager
protected org.springframework.context.ApplicationEventPublisher	publisher
protected org.springframework.transaction.PlatformTransactionManager	transactionManager
protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil	transUtil

Constructor Summary

Constructors

Constructor and Description
AbandonedProcessWorkerImpl()

Method Summary

Modifier and Type	Method and Description
void	execute(org.quartz.JobExecutionContext jobExecutionContext)
int	getAbandonedHandleThresholdSeconds() The quantity of time for which a ProcessStatus must be abandoned (i.e.
int	getAbandonedPurgeThresholdSeconds() The quantity of time for which a ProcessStatus must be archived before it is a candidate for deletion.
protected void	handleAbandonedProcesses()
void	init()
protected void	performAdditionalCleanup()
protected void	purgeOldProcesses()

Methods inherited from class com.broadleafcommerce.jobsevents.service.AbstractConsumerWorker

populateSystemEvents

Methods inherited from class java.lang.Object

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

Field Detail

transUtil

protected org.broadleafcommerce.common.util.StreamingTransactionCapableUtil transUtil

transactionManager

protected org.springframework.transaction.PlatformTransactionManager transactionManager

processDao

protected ProcessDao processDao

processManager

protected ProcessManager processManager

jobManager

protected ScheduledJobManager jobManager

publisher

@Autowired
protected org.springframework.context.ApplicationEventPublisher publisher

abandonedHandleThresholdSeconds

@Value(value="${process.abandoned.handle.threshold.seconds:60}")
protected int abandonedHandleThresholdSeconds

abandonedPurgeThresholdSeconds

@Value(value="${process.abandoned.purge.threshold.seconds:2592000}")
protected int abandonedPurgeThresholdSeconds

Constructor Detail

AbandonedProcessWorkerImpl

public AbandonedProcessWorkerImpl()

Method Detail

init

@PostConstruct
public void init()

execute

public void execute(org.quartz.JobExecutionContext jobExecutionContext)

purgeOldProcesses

protected void purgeOldProcesses()

handleAbandonedProcesses

protected void handleAbandonedProcesses()

performAdditionalCleanup

protected void performAdditionalCleanup()

getAbandonedHandleThresholdSeconds

public int getAbandonedHandleThresholdSeconds()

The quantity of time for which a ProcessStatus must be abandoned (i.e. ProcessStatus.getLastUpdated()) before it is a candidate for abandoned handling. The default value is 60 seconds. Handling generally takes the form of an attempt to resume the process, but can really be any operation that makes sense for rectifying a process that has been abandoned for any reason. See HandleAbandonedProcessEvent for more information on creating listeners to handle abandoned processes.

Returns:

getAbandonedPurgeThresholdSeconds

public int getAbandonedPurgeThresholdSeconds()

The quantity of time for which a ProcessStatus must be archived before it is a candidate for deletion. Default is 2592000 seconds (30 days). Use -1 to represent never purging.

Returns: