Package org.apache.syncope.core.provisioning.java.pushpull

Class AbstractProvisioningJobDelegate<T extends ProvisioningTask<T>>

java.lang.Object

org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate<T>

org.apache.syncope.core.provisioning.java.pushpull.AbstractProvisioningJobDelegate<T>

All Implemented Interfaces:

JobDelegate, SchedTaskJobDelegate

Direct Known Subclasses:

PullJobDelegate, PushJobDelegate

public abstract class AbstractProvisioningJobDelegate<T extends ProvisioningTask<T>>
extends AbstractSchedTaskJobDelegate<T>

Field Summary

Fields

Modifier and Type	Field	Description
protected AnyTypeDAO	anyTypeDAO	AnyTypeDAO DAO
protected ConnectorManager	connectorManager	ConnInstance loader.
protected EntityFactory	entityFactory
protected Optional<ProvisionSorter>	perContextProvisionSorter
protected PolicyDAO	policyDAO	Policy DAO.
protected ExternalResourceDAO	resourceDAO	Resource DAO.

Fields inherited from class org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate

auditManager, interrupt, interrupted, LOG, notificationManager, publisher, securityProperties, task, taskDAO, taskDataBinder, taskExecDAO, taskType, taskUtilsFactory

Fields inherited from interface org.apache.syncope.core.provisioning.api.job.JobDelegate

OPERATION_ID

Constructor Summary

Constructors

Constructor	Description
AbstractProvisioningJobDelegate()

Method Summary

Modifier and Type	Method	Description
protected String	createReport(Collection<ProvisioningReport> provResults, ExternalResource resource, boolean dryRun)	Create a textual report of the provisioning operation, based on the trace level.
protected String	doExecute(boolean dryRun, String executor, org.quartz.JobExecutionContext context)	The actual execution, delegated to child classes.
protected abstract String	doExecuteProvisioning(T task, Connector connector, boolean dryRun, String executor, org.quartz.JobExecutionContext context)
protected String	generate(Collection<ProvisioningReport> results, TraceLevel level)	Helper method to invoke logging per provisioning result, for the given trace level.
protected Connector	getConnector(T provisioningTask)
protected ProvisionSorter	getProvisionSorter(T task)
protected Class<T>	getTaskClassReference()
protected boolean	hasToBeRegistered(TaskExec<?> execution)	Template method to determine whether this job's task execution has to be persisted or not.

Methods inherited from class org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate

execute, interrupt, isInterrupted, register, setStatus

Methods inherited from class java.lang.Object

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

Field Detail

connectorManager

@Autowired
protected ConnectorManager connectorManager

ConnInstance loader.

anyTypeDAO

@Autowired
protected AnyTypeDAO anyTypeDAO

AnyTypeDAO DAO

resourceDAO

@Autowired
protected ExternalResourceDAO resourceDAO

Resource DAO.

entityFactory

@Autowired
protected EntityFactory entityFactory

policyDAO

@Autowired
protected PolicyDAO policyDAO

Policy DAO.

perContextProvisionSorter

protected Optional<ProvisionSorter> perContextProvisionSorter

Constructor Detail

AbstractProvisioningJobDelegate

public AbstractProvisioningJobDelegate()

Method Detail

getProvisionSorter

protected ProvisionSorter getProvisionSorter(T task)

generate

protected String generate(Collection<ProvisioningReport> results,
                          TraceLevel level)

Helper method to invoke logging per provisioning result, for the given trace level.

Parameters:

results - provisioning results

level - trace level

Returns:

report as string

createReport

protected String createReport(Collection<ProvisioningReport> provResults,
                              ExternalResource resource,
                              boolean dryRun)

Create a textual report of the provisioning operation, based on the trace level.

Parameters:

provResults - Provisioning results

resource - Provisioning resource

dryRun - dry run?

Returns:

report as string

getConnector

protected Connector getConnector(T provisioningTask)
                          throws org.quartz.JobExecutionException

Throws:

org.quartz.JobExecutionException

doExecute

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

Description copied from class: AbstractSchedTaskJobDelegate

The actual execution, delegated to child classes.

Specified by:

doExecute in class AbstractSchedTaskJobDelegate<T extends ProvisioningTask<T>>

Parameters:

dryRun - whether to actually touch the data

executor - the user executing this task

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

doExecuteProvisioning

protected abstract String doExecuteProvisioning(T task,
                                                Connector connector,
                                                boolean dryRun,
                                                String executor,
                                                org.quartz.JobExecutionContext context)
                                         throws org.quartz.JobExecutionException

Throws:

org.quartz.JobExecutionException

hasToBeRegistered

protected boolean hasToBeRegistered(TaskExec<?> execution)

Description copied from class: AbstractSchedTaskJobDelegate

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

Overrides:

hasToBeRegistered in class AbstractSchedTaskJobDelegate<T extends ProvisioningTask<T>>

Parameters:

execution - task execution

Returns:

whether to persist or not

getTaskClassReference

protected Class<T> getTaskClassReference()