com.broadleafcommerce.jobsevents.dao

Class ProcessDaoImpl

java.lang.Object

com.broadleafcommerce.jobsevents.dao.ProcessDaoImpl

All Implemented Interfaces:

ProcessDao

@Repository(value="blProcessDao")
public class ProcessDaoImpl
extends Object
implements ProcessDao

Author:

Jeff Fischer

See Also:

ProcessDao

Field Summary

Fields

Modifier and Type	Field and Description
protected javax.persistence.EntityManager	em
protected org.broadleafcommerce.profile.core.service.IdGenerationService	idGenerationService
protected DatabaseSystemEventNode	systemEventNode

Constructor Summary

Constructors

Constructor and Description
ProcessDaoImpl()

Method Summary

Modifier and Type	Method and Description
ProcessStatus	archive(ProcessStatus processStatus)
Boolean	containsRecentlyActiveByExecutionType(int thresholdSeconds, String executionType) Determine if there are currently any active ProcessStatus instances with the given executionType, or if there are any "recently" archived ProcessStatus instances of the given type.
void	delete(ProcessStatus processStatus)
List<ProcessStatus>	findAbandonedProcesses(int thresholdSeconds) Find the list of ProcessStatus instances whose ProcessStatus.getLastUpdated() time is older than the current database time subtracting the threshold.
ProcessStatus	findByExecution(Long executionId, String executionType) Find a ProcessStatus instance based on information tied to the async process associated.
List<ProcessStatus>	findOldArchivedProcesses(int thresholdSeconds) Find any processes that are archived and older than the current time - threshold.
List<Long>	getAllPersistedProcessIds() Retrieve all the processIds for all ProcessStatus instances
protected Date	getCurrentTime()
void	keepAlive(List<Long> processIds) Update the ProcessStatus.getLastUpdated() field to the current time of the database server.
ProcessStatus	loadByProcessId(Long processId)
void	refresh(ProcessStatus processStatus)
ProcessStatus	save(ProcessStatus processStatus)
ProcessStatus	unArchive(ProcessStatus processStatus)

Methods inherited from class java.lang.Object

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

Field Detail

em

protected javax.persistence.EntityManager em

idGenerationService

protected org.broadleafcommerce.profile.core.service.IdGenerationService idGenerationService

systemEventNode

protected DatabaseSystemEventNode systemEventNode

Constructor Detail

ProcessDaoImpl

public ProcessDaoImpl()

Method Detail

save

public ProcessStatus save(ProcessStatus processStatus)

Specified by:

save in interface ProcessDao

refresh

public void refresh(ProcessStatus processStatus)

Specified by:

refresh in interface ProcessDao

keepAlive

public void keepAlive(List<Long> processIds)

Description copied from interface: ProcessDao

Update the ProcessStatus.getLastUpdated() field to the current time of the database server.

Specified by:

keepAlive in interface ProcessDao

delete

public void delete(ProcessStatus processStatus)

Specified by:

delete in interface ProcessDao

archive

public ProcessStatus archive(ProcessStatus processStatus)

Specified by:

archive in interface ProcessDao

unArchive

public ProcessStatus unArchive(ProcessStatus processStatus)

Specified by:

unArchive in interface ProcessDao

getAllPersistedProcessIds

public List<Long> getAllPersistedProcessIds()

Description copied from interface: ProcessDao

Retrieve all the processIds for all ProcessStatus instances

Specified by:

getAllPersistedProcessIds in interface ProcessDao

Returns:

loadByProcessId

public ProcessStatus loadByProcessId(Long processId)

Specified by:

loadByProcessId in interface ProcessDao

findAbandonedProcesses

public List<ProcessStatus> findAbandonedProcesses(int thresholdSeconds)

Description copied from interface: ProcessDao

Find the list of ProcessStatus instances whose ProcessStatus.getLastUpdated() time is older than the current database time subtracting the threshold.

Specified by:

findAbandonedProcesses in interface ProcessDao

Returns:

containsRecentlyActiveByExecutionType

public Boolean containsRecentlyActiveByExecutionType(int thresholdSeconds,
                                                     String executionType)

Description copied from interface: ProcessDao

Determine if there are currently any active ProcessStatus instances with the given executionType, or if there are any "recently" archived ProcessStatus instances of the given type. Older archived statuses would not cause this method to return true.

Specified by:

containsRecentlyActiveByExecutionType in interface ProcessDao

Parameters:

thresholdSeconds - The number of seconds in the past used to check for ProcessStatus last updated. Any status older than this threshold is not considered.

executionType - an identifying type value (e.g. the class name from an entity used in the async process)

Returns:

whether or not an valid statuses were found

findOldArchivedProcesses

public List<ProcessStatus> findOldArchivedProcesses(int thresholdSeconds)

Description copied from interface: ProcessDao

Find any processes that are archived and older than the current time - threshold.

Specified by:

findOldArchivedProcesses in interface ProcessDao

Returns:

findByExecution

public ProcessStatus findByExecution(Long executionId,
                                     String executionType)

Description copied from interface: ProcessDao

Find a ProcessStatus instance based on information tied to the async process associated.

Specified by:

findByExecution in interface ProcessDao

Parameters:

executionId - an identifying long id (e.g. the primary key from an entity used in the async process)

executionType - an identifying tyep value (e.g. the class name from an entity used in the async process)

Returns:

getCurrentTime

protected Date getCurrentTime()