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
FieldsModifier and TypeFieldDescriptionprotected PullResultHandlerDispatcher
protected GroupPullResultHandler
protected GroupDAO
protected InboundMatcher
protected final Map
<String, InboundActions> protected Optional
<ReconFilterBuilder> protected PlainSchemaDAO
protected ProvisioningProfile
<PullTask, InboundActions> protected ProvisionSorter
protected PlainAttrValidationManager
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 -
Method Summary
Modifier and TypeMethodDescriptionprotected AnyObjectPullResultHandler
protected GroupPullResultHandler
protected RealmPullResultHandler
protected UserPullResultHandler
protected String
doExecute
(JobExecutionContext context) The actual execution, delegated to child classes.protected List
<InboundActions> getInboundActions
(List<? extends Implementation> impls) protected ReconFilterBuilder
protected void
init
(TaskType taskType, String taskKey, JobExecutionContext context) void
reportHandled
(String objectClass, Name name) protected void
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
Methods 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:StoppableSchedTaskJobDelegate
Request the current Job to stop the execution of the running Task.- Specified by:
stop
in interfaceStoppableSchedTaskJobDelegate
-
doExecute
Description copied from class:AbstractSchedTaskJobDelegate
The actual execution, delegated to child classes.- Specified by:
doExecute
in 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:
setLatestSyncToken
in interfaceSyncopePullExecutor
-
reportHandled
- Specified by:
reportHandled
in interfaceSyncopePullExecutor
-