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

Class SinglePullJobDelegate

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

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

All Implemented Interfaces:

SchedTaskJobDelegate, StoppableSchedTaskJobDelegate, SyncopePullExecutor, SyncopeSinglePullExecutor

public class SinglePullJobDelegate
extends PullJobDelegate
implements SyncopeSinglePullExecutor

Field Summary

Fields

Modifier and Type	Field	Description
protected PullResultHandlerDispatcher	dispatcher
protected GroupPullResultHandler	ghandler
protected GroupDAO	groupDAO
protected ImplementationDAO	implementationDAO
protected InboundMatcher	inboundMatcher
protected final Map<String,SyncToken>	latestSyncTokens
protected final Map<String,InboundActions>	perContextActions
protected PlainSchemaDAO	plainSchemaDAO
protected ProvisioningProfile<PullTask,InboundActions>	profile
protected ProvisionSorter	provisionSorter
protected RealmSearchDAO	realmSearchDAO
protected PlainAttrValidationManager	validator

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

perContextReconFilterBuilder

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
SinglePullJobDelegate()

Method Summary

Modifier and Type	Method	Description
protected AnyObjectPullResultHandler	buildAnyObjectHandler()
protected GroupPullResultHandler	buildGroupHandler()
protected RealmPullResultHandler	buildRealmHandler()
protected UserPullResultHandler	buildUserHandler()
protected List<InboundActions>	getInboundActions(List<? extends Implementation> impls)
List<ProvisioningReport>	pull(ExternalResource resource, Provision provision, Connector connector, ReconFilterBuilder reconFilterBuilder, Set<String> moreAttrsToGet, PullTaskTO pullTaskTO, String executor)
void	reportHandled(String objectClass, Name name)
protected void	setGroupOwners()
void	setLatestSyncToken(String objectClass, SyncToken latestSyncToken)

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

doExecute, getReconFilterBuilder, init, stop

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

implementationDAO

@Autowired
protected ImplementationDAO implementationDAO

realmSearchDAO

@Autowired
protected RealmSearchDAO realmSearchDAO

groupDAO

@Autowired
protected GroupDAO groupDAO

plainSchemaDAO

@Autowired
protected PlainSchemaDAO plainSchemaDAO

inboundMatcher

@Autowired
protected InboundMatcher inboundMatcher

validator

@Autowired
protected PlainAttrValidationManager validator

latestSyncTokens

protected final Map<String,SyncToken> latestSyncTokens

perContextActions

protected final Map<String,InboundActions> perContextActions

provisionSorter

protected ProvisionSorter provisionSorter

profile

protected ProvisioningProfile<PullTask,InboundActions> profile

dispatcher

protected PullResultHandlerDispatcher dispatcher

ghandler

protected GroupPullResultHandler ghandler

Constructor Details

SinglePullJobDelegate

public SinglePullJobDelegate()

Method Details

pull

public List<ProvisioningReport> pull(ExternalResource resource,
 Provision provision,
 Connector connector,
 ReconFilterBuilder reconFilterBuilder,
 Set<String> moreAttrsToGet,
 PullTaskTO pullTaskTO,
 String executor)
                              throws JobExecutionException

Specified by:

pull in interface SyncopeSinglePullExecutor

Throws:

JobExecutionException

buildRealmHandler

protected RealmPullResultHandler buildRealmHandler()

buildAnyObjectHandler

protected AnyObjectPullResultHandler buildAnyObjectHandler()

buildUserHandler

protected UserPullResultHandler buildUserHandler()

buildGroupHandler

protected GroupPullResultHandler buildGroupHandler()

getInboundActions

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

setGroupOwners

protected void setGroupOwners()

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