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:

SchedTaskJobDelegate

Direct Known Subclasses:

LiveSyncJobDelegate, PullJobDelegate, PushJobDelegate

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

Field Summary

Fields

Modifier and Type	Field	Description
protected AnyTypeDAO	anyTypeDAO
protected AnyUtilsFactory	anyUtilsFactory
protected Connector	connector
protected ConnectorManager	connectorManager
protected EntityFactory	entityFactory
protected Optional<ProvisionSorter>	perContextProvisionSorter
protected PolicyDAO	policyDAO
protected ExternalResourceDAO	resourceDAO

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

auditManager, executor, LOG, manageOperationId, notificationManager, publisher, securityProperties, task, taskDAO, taskExecDAO, taskType, taskUtilsFactory

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	generate(Collection<ProvisioningReport> results, TraceLevel level)	Helper method to invoke logging per provisioning result, for the given trace level.
protected ProvisionSorter	getProvisionSorter(T task)
protected boolean	hasToBeRegistered(TaskExec<?> execution)	Template method to determine whether this job's task execution has to be persisted or not.
protected void	init(TaskType taskType, String taskKey, JobExecutionContext context)

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

doExecute, end, endExecution, execute, initExecution, register, setStatus

Methods inherited from class java.lang.Object

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

Field Details

connectorManager

@Autowired
protected ConnectorManager connectorManager

anyTypeDAO

@Autowired
protected AnyTypeDAO anyTypeDAO

resourceDAO

@Autowired
protected ExternalResourceDAO resourceDAO

entityFactory

@Autowired
protected EntityFactory entityFactory

anyUtilsFactory

@Autowired
protected AnyUtilsFactory anyUtilsFactory

policyDAO

@Autowired
protected PolicyDAO policyDAO

perContextProvisionSorter

protected Optional<ProvisionSorter> perContextProvisionSorter

connector

protected Connector connector

Constructor Details

AbstractProvisioningJobDelegate

public AbstractProvisioningJobDelegate()

Method Details

init

protected void init(TaskType taskType,
 String taskKey,
 JobExecutionContext context)
             throws JobExecutionException

Overrides:

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

Throws:

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

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