com.broadleafcommerce.jobsevents.service

Class AbandonedProcessWorkerImpl

java.lang.Object

com.broadleafcommerce.jobsevents.service.AbstractConsumerWorker

com.broadleafcommerce.jobsevents.service.AbandonedProcessWorkerImpl

All Implemented Interfaces:

ConsumeWorker, ScheduledDeployManagerAware

@Component(value="blAbandonedProcessWorker")
 @Scope(value="prototype")
 @Lazy
public class AbandonedProcessWorkerImpl
extends AbstractConsumerWorker
implements ScheduledDeployManagerAware

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.

Author:

Jeff Fischer

Field Summary

Fields

Modifier and Type	Field and Description
protected int	abandonedHandleThresholdSeconds
protected int	abandonedPurgeThresholdSeconds
protected boolean	allowRetry
protected ScheduledDeployManager	deployManager
protected IncognitoEnvironmentDetector	detector
protected ProcessDao	processDao
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()
void	setScheduledDeployManager(ScheduledDeployManager deployManager)

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

detector

protected IncognitoEnvironmentDetector detector

deployManager

protected ScheduledDeployManager deployManager

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:86400}")
protected int abandonedPurgeThresholdSeconds

allowRetry

@Value(value="${process.abandoned.allow.retry:true}")
protected boolean allowRetry

Constructor Detail

AbandonedProcessWorkerImpl

public AbandonedProcessWorkerImpl()

Method Detail

init

@PostConstruct
public void init()

execute

public void execute(org.quartz.JobExecutionContext jobExecutionContext)

Specified by:

execute in interface ConsumeWorker

setScheduledDeployManager

public void setScheduledDeployManager(ScheduledDeployManager deployManager)

Specified by:

setScheduledDeployManager in interface ScheduledDeployManagerAware

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: