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

Class PullJobDelegate

java.lang.Object

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

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

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

All Implemented Interfaces:

SchedTaskJobDelegate, StoppableSchedTaskJobDelegate, SyncopePullExecutor

Direct Known Subclasses:

SinglePullJobDelegate, StreamPullJobDelegate

public class PullJobDelegate
extends AbstractProvisioningJobDelegate<PullTask>
implements SyncopePullExecutor, StoppableSchedTaskJobDelegate

Field Summary

Fields

Modifier and Type	Field	Description
protected PullResultHandlerDispatcher	dispatcher
protected GroupDAO	groupDAO
protected final Map<String,MutablePair<Integer,String>>	handled
protected InboundMatcher	inboundMatcher
protected final Map<String,SyncToken>	latestSyncTokens
protected final Map<String,InboundActions>	perContextActions
protected Optional<ReconFilterBuilder>	perContextReconFilterBuilder
protected PlainSchemaDAO	plainSchemaDAO
protected ProvisioningProfile<PullTask,InboundActions>	profile
protected PlainAttrValidationManager	validator
protected VirSchemaDAO	virSchemaDAO

Fields inherited from class org.apache.syncope.core.provisioning.java.pushpull.AbstractProvisioningJobDelegate

anyTypeDAO, anyUtilsFactory, connector, connectorManager, entityFactory, perContextProvisionSorter, policyDAO, 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
PullJobDelegate()

Method Summary

Modifier and Type	Method	Description
protected AnyObjectPullResultHandler	buildAnyObjectHandler()
protected GroupPullResultHandler	buildGroupHandler()
protected RealmPullResultHandler	buildRealmHandler()
protected UserPullResultHandler	buildUserHandler()
protected String	doExecute(JobExecutionContext context)	The actual execution, delegated to child classes.
protected List<InboundActions>	getInboundActions(List<? extends Implementation> impls)
protected ReconFilterBuilder	getReconFilterBuilder(PullTask task)
protected void	init(TaskType taskType, String taskKey, JobExecutionContext context)
void	reportHandled(String objectClass, Name name)
static void	setGroupOwners(GroupPullResultHandler ghandler, GroupDAO groupDAO, AnyTypeDAO anyTypeDAO, InboundMatcher inboundMatcher, ProvisioningProfile<PullTask,InboundActions> profile)
void	setLatestSyncToken(String objectClass, SyncToken latestSyncToken)
void	stop()	Request the current Job to stop the execution of the running Task.

Methods inherited from class org.apache.syncope.core.provisioning.java.pushpull.AbstractProvisioningJobDelegate

createReport, generate, getProvisionSorter, hasToBeRegistered

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

end, endExecution, execute, initExecution, register, setStatus

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.syncope.core.provisioning.api.job.SchedTaskJobDelegate

execute

Field Details

groupDAO

@Autowired
protected GroupDAO groupDAO

plainSchemaDAO

@Autowired
protected PlainSchemaDAO plainSchemaDAO

virSchemaDAO

@Autowired
protected VirSchemaDAO virSchemaDAO

inboundMatcher

@Autowired
protected InboundMatcher inboundMatcher

validator

@Autowired
protected PlainAttrValidationManager validator

latestSyncTokens

protected final Map<String,SyncToken> latestSyncTokens

profile

protected ProvisioningProfile<PullTask,InboundActions> profile

handled

protected final Map<String,MutablePair<Integer,String>> handled

perContextActions

protected final Map<String,InboundActions> perContextActions

perContextReconFilterBuilder

protected Optional<ReconFilterBuilder> perContextReconFilterBuilder

dispatcher

protected PullResultHandlerDispatcher dispatcher

Constructor Details

PullJobDelegate

public PullJobDelegate()

Method Details

setGroupOwners

public static void setGroupOwners(GroupPullResultHandler ghandler,
 GroupDAO groupDAO,
 AnyTypeDAO anyTypeDAO,
 InboundMatcher inboundMatcher,
 ProvisioningProfile<PullTask,InboundActions> profile)

setLatestSyncToken

public void setLatestSyncToken(String objectClass,
 SyncToken latestSyncToken)

Specified by:

setLatestSyncToken in interface SyncopePullExecutor

reportHandled

public void reportHandled(String objectClass,
 Name name)

Specified by:

reportHandled in interface SyncopePullExecutor

getInboundActions

protected List<InboundActions> getInboundActions(List<? extends Implementation> impls)

getReconFilterBuilder

protected ReconFilterBuilder getReconFilterBuilder(PullTask task)
                                            throws ClassNotFoundException

Throws:

ClassNotFoundException

buildRealmHandler

protected RealmPullResultHandler buildRealmHandler()

buildAnyObjectHandler

protected AnyObjectPullResultHandler buildAnyObjectHandler()

buildUserHandler

protected UserPullResultHandler buildUserHandler()

buildGroupHandler

protected GroupPullResultHandler buildGroupHandler()

init

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

Overrides:

init in class AbstractProvisioningJobDelegate<PullTask>

Throws:

JobExecutionException

stop

public void stop()

Description copied from interface: StoppableSchedTaskJobDelegate

Request the current Job to stop the execution of the running Task.

Specified by:

stop in interface StoppableSchedTaskJobDelegate

doExecute

protected String doExecute(JobExecutionContext context)
                    throws JobExecutionException

Description copied from class: AbstractSchedTaskJobDelegate

The actual execution, delegated to child classes.

Specified by:

doExecute in class AbstractSchedTaskJobDelegate<PullTask>

Parameters:

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

Returns:

the task execution status to be set

Throws:

JobExecutionException - if anything goes wrong