Package ch.tocco.nice2.tasks.impl.progress

Class ProgressPersistenceManagerImpl

java.lang.Object

ch.tocco.nice2.tasks.impl.progress.ProgressPersistenceManagerImpl

All Implemented Interfaces:

ProgressPersistenceManager

@Component
public class ProgressPersistenceManagerImpl
extends Object
implements ProgressPersistenceManager

Constructor Summary

Constructors

Constructor	Description
ProgressPersistenceManagerImpl(CommandExecutor commandExecutor, org.slf4j.Logger log, TextResources textResources, PrincipalService principalService, CascadingDeleteService cascadingDeleteService, QueryBuilderFactory queryBuilderFactory)

Method Summary

Modifier and Type	Method	Description
ProgressBean	createProgress(String taskId, String taskName)	Create a new ProgressBean object.
void	delete(String taskId)	Delete a Task_execution entity.
Optional<LogEntry>	findLatestLogEntry(String taskId)
Optional<LogEntry>	findLogEntryByState(String state)	Find a single LogEntry for a given state value.
List<ProgressBean>	getProgressOfRunningTasks()	Get progress of all running tasks.
void	saveLogEntry(LogEntry logEntry)	Save the given LogEntry.
void	saveProgress(Progress progress)	Save the given Progress.
void	setupTaskExecutionEnvironment(String taskId, String jobKey, String type, String name, long startDate, String details, TaskExecutionStatus initialStatus)
void	stopUncompletedTaskExecutions()	Set all Task_execution entities to stoppedstopped, which are still running.
void	updateStartDate(String taskId, long startDate)	Update the start date on the Task_execution entity with the given task id.
void	updateTaskExecutionStatus(String taskId, TaskExecutionStatus status)	Update the status of the Task_execution entity with the given task id.

Methods inherited from class java.lang.Object

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

Methods inherited from interface ch.tocco.nice2.tasks.impl.progress.ProgressPersistenceManager

setupTaskExecutionEnvironment

Constructor Details

ProgressPersistenceManagerImpl

public ProgressPersistenceManagerImpl(CommandExecutor commandExecutor,
 org.slf4j.Logger log,
 TextResources textResources,
 PrincipalService principalService,
 CascadingDeleteService cascadingDeleteService,
 QueryBuilderFactory queryBuilderFactory)

Method Details

setupTaskExecutionEnvironment

public void setupTaskExecutionEnvironment(String taskId,
 String jobKey,
 String type,
 String name,
 long startDate,
 String details,
 TaskExecutionStatus initialStatus)

Specified by:

setupTaskExecutionEnvironment in interface ProgressPersistenceManager

updateStartDate

public void updateStartDate(String taskId,
 long startDate)

Description copied from interface: ProgressPersistenceManager

Update the start date on the Task_execution entity with the given task id.

Specified by:

updateStartDate in interface ProgressPersistenceManager

Parameters:

taskId - The task id of the Task_execution to modify.

startDate - The new start date to set.

delete

public void delete(String taskId)

Description copied from interface: ProgressPersistenceManager

Delete a Task_execution entity.

Specified by:

delete in interface ProgressPersistenceManager

Parameters:

taskId - The task id of the Task_execution entity to delete.

stopUncompletedTaskExecutions

public void stopUncompletedTaskExecutions()

Description copied from interface: ProgressPersistenceManager

Set all Task_execution entities to stoppedstopped, which are still running. Should only be called before the scheduler has been started.

Specified by:

stopUncompletedTaskExecutions in interface ProgressPersistenceManager

updateTaskExecutionStatus

public void updateTaskExecutionStatus(String taskId,
 TaskExecutionStatus status)

Description copied from interface: ProgressPersistenceManager

Update the status of the Task_execution entity with the given task id.

Specified by:

updateTaskExecutionStatus in interface ProgressPersistenceManager

Parameters:

taskId - The task id of the Task_execution entity to update.

status - The new status to set.

createProgress

public ProgressBean createProgress(String taskId,
 String taskName)

Description copied from interface: ProgressPersistenceManager

Create a new ProgressBean object.

Specified by:

createProgress in interface ProgressPersistenceManager

Parameters:

taskId - The task id for the ProgressBean.

taskName - The task name for ProgressBean.

Returns:

the created ProgressBean.

saveProgress

public void saveProgress(Progress progress)

Description copied from interface: ProgressPersistenceManager

Save the given Progress.

Specified by:

saveProgress in interface ProgressPersistenceManager

Parameters:

progress - The progress to save.

getProgressOfRunningTasks

public List<ProgressBean> getProgressOfRunningTasks()

Description copied from interface: ProgressPersistenceManager

Get progress of all running tasks.

Specified by:

getProgressOfRunningTasks in interface ProgressPersistenceManager

Returns:

progress of all running tasks.

saveLogEntry

public void saveLogEntry(LogEntry logEntry)

Description copied from interface: ProgressPersistenceManager

Save the given LogEntry.

Specified by:

saveLogEntry in interface ProgressPersistenceManager

Parameters:

logEntry - The log entry to save.

findLogEntryByState

public Optional<LogEntry> findLogEntryByState(String state)

Description copied from interface: ProgressPersistenceManager

Find a single LogEntry for a given state value. This value must uniquely identify the log entry!

If more than one result is found, an exception is thrown. Otherwise either the single result is returned or none.

Specified by:

findLogEntryByState in interface ProgressPersistenceManager

findLatestLogEntry

public Optional<LogEntry> findLatestLogEntry(String taskId)

Specified by:

findLatestLogEntry in interface ProgressPersistenceManager