org.apache.syncope.core.provisioning.java.job

Class AbstractSchedTaskJobDelegate

java.lang.Object

org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate

All Implemented Interfaces:

JobDelegate, SchedTaskJobDelegate

Direct Known Subclasses:

AbstractProvisioningJobDelegate, ElasticsearchReindex, ExpiredAccessTokenCleanup, ExpiredBatchCleanup, GroupMemberProvisionTaskJobDelegate, TestSampleJobDelegate

public abstract class AbstractSchedTaskJobDelegate
extends Object
implements SchedTaskJobDelegate

Field Summary

Fields

Modifier and Type	Field and Description
protected AuditManager	auditManager Audit manager.
protected EntityFactory	entityFactory
protected boolean	interrupt
protected boolean	interrupted
protected static org.slf4j.Logger	LOG
protected NotificationManager	notificationManager Notification manager.
protected ApplicationEventPublisher	publisher
protected SchedTask	task The actual task to be executed.
protected TaskDAO	taskDAO Task DAO.
protected TaskDataBinder	taskDataBinder
protected TaskExecDAO	taskExecDAO Task execution DAO.

Constructor Summary

Constructors

Constructor and Description
AbstractSchedTaskJobDelegate()

Method Summary

Modifier and Type	Method and Description
protected abstract String	doExecute(boolean dryRun, org.quartz.JobExecutionContext context) The actual execution, delegated to child classes.
void	execute(String taskKey, boolean dryRun, org.quartz.JobExecutionContext context) Executes a Quartz Job to run the given Task.
protected boolean	hasToBeRegistered(TaskExec execution) Template method to determine whether this job's task execution has to be persisted or not.
void	interrupt()
boolean	isInterrupted()
protected void	register(TaskExec execution)
protected void	setStatus(String status)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

task

protected SchedTask task

The actual task to be executed.

taskExecDAO

@Autowired
protected TaskExecDAO taskExecDAO

Task execution DAO.

taskDAO

@Autowired
protected TaskDAO taskDAO

Task DAO.

entityFactory

@Autowired
protected EntityFactory entityFactory

taskDataBinder

@Autowired
protected TaskDataBinder taskDataBinder

notificationManager

@Autowired
protected NotificationManager notificationManager

Notification manager.

auditManager

@Autowired
protected AuditManager auditManager

Audit manager.

publisher

@Autowired
protected ApplicationEventPublisher publisher

interrupt

protected boolean interrupt

interrupted

protected boolean interrupted

Constructor Detail

AbstractSchedTaskJobDelegate

public AbstractSchedTaskJobDelegate()

Method Detail

setStatus

protected void setStatus(String status)

interrupt

public void interrupt()

Specified by:

interrupt in interface JobDelegate

isInterrupted

public boolean isInterrupted()

Specified by:

isInterrupted in interface JobDelegate

execute

@Transactional
public void execute(String taskKey,
                                   boolean dryRun,
                                   org.quartz.JobExecutionContext context)
                            throws org.quartz.JobExecutionException

Description copied from interface: SchedTaskJobDelegate

Executes a Quartz Job to run the given Task.

Specified by:

execute in interface SchedTaskJobDelegate

Parameters:

taskKey - Task key to run

dryRun - indicates if execution shall be simulated with no actual changes

context - Quartz' execution context, can be used to pass parameters to the job

Throws:

org.quartz.JobExecutionException - if anything goes wrong

doExecute

protected abstract String doExecute(boolean dryRun,
                                    org.quartz.JobExecutionContext context)
                             throws org.quartz.JobExecutionException

The actual execution, delegated to child classes.

Parameters:

dryRun - whether to actually touch the data

context - Quartz' execution context, can be used to pass parameters to the job

Returns:

the task execution status to be set

Throws:

org.quartz.JobExecutionException - if anything goes wrong

hasToBeRegistered

protected boolean hasToBeRegistered(TaskExec execution)

Template method to determine whether this job's task execution has to be persisted or not.

Parameters:

execution - task execution

Returns:

wether to persist or not

register

protected void register(TaskExec execution)