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:
JobDelegate,SchedTaskJobDelegate,StoppableJobDelegate,SyncopePullExecutor
- Direct Known Subclasses:
SinglePullJobDelegate,StreamPullJobDelegate
public class PullJobDelegate
extends AbstractProvisioningJobDelegate<PullTask>
implements SyncopePullExecutor, StoppableJobDelegate
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected PullResultHandlerDispatcherprotected GroupPullResultHandlerprotected GroupDAOprotected InboundMatcherprotected final Map<String, InboundActions> protected Optional<ReconFilterBuilder> protected PlainSchemaDAOprotected ProvisioningProfile<PullTask, InboundActions> protected ProvisionSorterprotected PlainAttrValidationManagerFields inherited from class org.apache.syncope.core.provisioning.java.pushpull.AbstractProvisioningJobDelegate
anyTypeDAO, anyUtilsFactory, connector, connectorManager, entityFactory, perContextProvisionSorter, policyDAO, resourceDAOFields 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 -
Method Summary
Modifier and TypeMethodDescriptionprotected AnyObjectPullResultHandlerprotected GroupPullResultHandlerprotected RealmPullResultHandlerprotected UserPullResultHandlerprotected StringdoExecute(JobExecutionContext context) The actual execution, delegated to child classes.protected List<InboundActions> getInboundActions(List<? extends Implementation> impls) protected ReconFilterBuilderprotected voidinit(TaskType taskType, String taskKey, JobExecutionContext context) voidreportHandled(String objectClass, Name name) protected voidvoidsetLatestSyncToken(String objectClass, SyncToken latestSyncToken) voidstop()Request the current Job to stop the execution.Methods inherited from class org.apache.syncope.core.provisioning.java.pushpull.AbstractProvisioningJobDelegate
createReport, generate, getProvisionSorter, hasToBeRegisteredMethods inherited from class org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate
end, endExecution, execute, initExecution, register, setStatusMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.syncope.core.provisioning.api.pushpull.SyncopePullExecutor
reportHandled, setLatestSyncToken
-
Field Details
-
perContextReconFilterBuilder
-
groupDAO
-
plainSchemaDAO
-
inboundMatcher
-
validator
-
latestSyncTokens
-
perContextActions
-
provisionSorter
-
profile
-
dispatcher
-
ghandler
-
-
Constructor Details
-
PullJobDelegate
public PullJobDelegate()
-
-
Method Details
-
getReconFilterBuilder
- Throws:
ClassNotFoundException
-
init
protected void init(TaskType taskType, String taskKey, JobExecutionContext context) throws JobExecutionException - Throws:
JobExecutionException
-
stop
public void stop()Description copied from interface:StoppableJobDelegateRequest the current Job to stop the execution.- Specified by:
stopin interfaceStoppableJobDelegate
-
doExecute
Description copied from class:AbstractSchedTaskJobDelegateThe actual execution, delegated to child classes.- Specified by:
doExecutein classAbstractSchedTaskJobDelegate<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
-
buildRealmHandler
-
buildAnyObjectHandler
-
buildUserHandler
-
buildGroupHandler
-
getInboundActions
-
setGroupOwners
protected void setGroupOwners() -
setLatestSyncToken
- Specified by:
setLatestSyncTokenin interfaceSyncopePullExecutor
-
reportHandled
- Specified by:
reportHandledin interfaceSyncopePullExecutor
-