net.datenwerke.scheduler.service.scheduler.stores

Interface JobExecutionCompanion

All Known Implementing Classes:

JobExecutionCompanionImpl, JpaExecutionCompanion

public interface JobExecutionCompanion

Method Summary

Modifier and Type	Method and Description
void	beginInnerTransaction(SchedulerTask schedulerTask)
AbstractJob	beginSchedulerTask(AbstractJob job)
void	endSchedulerTask(AbstractJob job, ExecutionLogEntry logEntry, boolean badFailure)
void	failExecutingJob(AbstractJob job)
void	finishInnerTransaction(SchedulerTask schedulerTask, boolean success)
void	flush()
ActionEntry	initActionEntry(ExecutionLogEntry logEntry)
AbstractAction	initActionForExecution(AbstractAction action)
ExecutionLogEntry	initHistoryEntry(AbstractJob job)
JobEntry	initJobEntry(ExecutionLogEntry entry)
AbstractJob	initJobForExecution(AbstractJob job)
void	resetWaitingJob(AbstractJob job)
void	updateStateAfterActionExecution(AbstractJob job, ExecutionLogEntry entry, ActionEntry actionEntry, boolean success)
void	updateStateAfterJobExecution(AbstractJob job, ExecutionLogEntry entry, JobEntry jobEntry, boolean success)

Method Detail

initJobForExecution

AbstractJob initJobForExecution(AbstractJob job)

beginSchedulerTask

AbstractJob beginSchedulerTask(AbstractJob job)

endSchedulerTask

void endSchedulerTask(AbstractJob job,
                      ExecutionLogEntry logEntry,
                      boolean badFailure)

updateStateAfterJobExecution

void updateStateAfterJobExecution(AbstractJob job,
                                  ExecutionLogEntry entry,
                                  JobEntry jobEntry,
                                  boolean success)

initHistoryEntry

ExecutionLogEntry initHistoryEntry(AbstractJob job)

updateStateAfterActionExecution

void updateStateAfterActionExecution(AbstractJob job,
                                     ExecutionLogEntry entry,
                                     ActionEntry actionEntry,
                                     boolean success)

initActionForExecution

AbstractAction initActionForExecution(AbstractAction action)

beginInnerTransaction

void beginInnerTransaction(SchedulerTask schedulerTask)

finishInnerTransaction

void finishInnerTransaction(SchedulerTask schedulerTask,
                            boolean success)

failExecutingJob

void failExecutingJob(AbstractJob job)

resetWaitingJob

void resetWaitingJob(AbstractJob job)

flush

void flush()

initActionEntry

ActionEntry initActionEntry(ExecutionLogEntry logEntry)

initJobEntry

JobEntry initJobEntry(ExecutionLogEntry entry)