com.broadleafcommerce.jobsevents.dao

Class ProcessManagementDaoImpl

java.lang.Object

com.broadleafcommerce.jobsevents.dao.ProcessManagementDaoImpl

All Implemented Interfaces:

ProcessManagementDao

@Repository(value="blProcessManagementDao")
 @Lazy
public class ProcessManagementDaoImpl
extends Object
implements ProcessManagementDao

Author:

Jeff Fischer

See Also:

ProcessManagementDao

Field Summary

Fields

Modifier and Type	Field and Description
protected javax.persistence.EntityManager	em
protected DatabaseSystemEventNode	systemEventNode

Constructor Summary

Constructors

Constructor and Description
ProcessManagementDaoImpl()

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.
List<ProcessStatus>	findAllByExecution(Long executionId, String executionType, int maxResults) Find all ProcessStatus instances based on information tied to the async process associated.
ProcessStatus	findByExecution(Long executionId, String executionType) Find the first active 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.
void	finish(Long processId) Records the time when the process finished executing.
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.
protected void	keepAliveUpdate(List<Long> processIdsPart)
ProcessStatus	loadByProcessId(Long processId)
void	refresh(ProcessStatus processStatus)
ProcessStatus	save(ProcessStatus processStatus)
void	start(Long processId) Records the time when the process began to execute.
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

systemEventNode

protected DatabaseSystemEventNode systemEventNode

Constructor Detail

ProcessManagementDaoImpl

public ProcessManagementDaoImpl()

Method Detail

save

public ProcessStatus save(ProcessStatus processStatus)

Specified by:

save in interface ProcessManagementDao

refresh

public void refresh(ProcessStatus processStatus)

Specified by:

refresh in interface ProcessManagementDao

keepAlive

public void keepAlive(List<Long> processIds)

Description copied from interface: ProcessManagementDao

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

Specified by:

keepAlive in interface ProcessManagementDao

keepAliveUpdate

protected void keepAliveUpdate(List<Long> processIdsPart)

start

public void start(Long processId)

Description copied from interface: ProcessManagementDao

Records the time when the process began to execute.

Specified by:

start in interface ProcessManagementDao

finish

public void finish(Long processId)

Description copied from interface: ProcessManagementDao

Records the time when the process finished executing.

Specified by:

finish in interface ProcessManagementDao

delete

public void delete(ProcessStatus processStatus)

Specified by:

delete in interface ProcessManagementDao

archive

public ProcessStatus archive(ProcessStatus processStatus)

Specified by:

archive in interface ProcessManagementDao

unArchive

public ProcessStatus unArchive(ProcessStatus processStatus)

Specified by:

unArchive in interface ProcessManagementDao

getAllPersistedProcessIds

public List<Long> getAllPersistedProcessIds()

Description copied from interface: ProcessManagementDao

Retrieve all the processIds for all ProcessStatus instances

Specified by:

getAllPersistedProcessIds in interface ProcessManagementDao

Returns:

loadByProcessId

public ProcessStatus loadByProcessId(Long processId)

Specified by:

loadByProcessId in interface ProcessManagementDao

findAbandonedProcesses

public List<ProcessStatus> findAbandonedProcesses(int thresholdSeconds)

Description copied from interface: ProcessManagementDao

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 ProcessManagementDao

Returns:

containsRecentlyActiveByExecutionType

public Boolean containsRecentlyActiveByExecutionType(int thresholdSeconds,
                                                     String executionType)

Description copied from interface: ProcessManagementDao

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 ProcessManagementDao

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: ProcessManagementDao

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

Specified by:

findOldArchivedProcesses in interface ProcessManagementDao

Returns:

findByExecution

public ProcessStatus findByExecution(Long executionId,
                                     String executionType)

Description copied from interface: ProcessManagementDao

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

Specified by:

findByExecution in interface ProcessManagementDao

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:

findAllByExecution

public List<ProcessStatus> findAllByExecution(Long executionId,
                                              String executionType,
                                              int maxResults)

Description copied from interface: ProcessManagementDao

Find all ProcessStatus instances based on information tied to the async process associated.

Specified by:

findAllByExecution in interface ProcessManagementDao

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)

maxResults - maximum quantity of results to acquire

Returns:

getCurrentTime

protected Date getCurrentTime()