Class StreamPullJobDelegate
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.stream.StreamPullJobDelegate
- All Implemented Interfaces:
JobDelegate,SchedTaskJobDelegate,StoppableJobDelegate,SyncopeStreamPullExecutor,SyncopePullExecutor
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected PullResultHandlerDispatcherprotected GroupPullResultHandlerprotected GroupDAOprotected InboundMatcherprotected final Map<String, InboundActions> protected PlainSchemaDAOprotected ProvisioningProfile<PullTask, InboundActions> protected ProvisionSorterprotected PlainAttrValidationManagerFields inherited from class org.apache.syncope.core.provisioning.java.pushpull.PullJobDelegate
perContextReconFilterBuilderFields 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 List<InboundActions> getInboundActions(List<? extends Implementation> impls) pull(AnyType anyType, String keyColumn, List<String> columns, ConflictResolutionAction conflictResolutionAction, String inboundCorrelationRule, Connector connector, PullTaskTO pullTaskTO, String executor) voidreportHandled(String objectClass, Name name) protected voidvoidsetLatestSyncToken(String objectClass, SyncToken latestSyncToken) Methods inherited from class org.apache.syncope.core.provisioning.java.pushpull.PullJobDelegate
doExecute, getReconFilterBuilder, init, stopMethods 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
-
groupDAO
-
plainSchemaDAO
-
inboundMatcher
-
validator
-
latestSyncTokens
-
perContextActions
-
provisionSorter
-
profile
-
dispatcher
-
ghandler
-
-
Constructor Details
-
StreamPullJobDelegate
public StreamPullJobDelegate()
-
-
Method Details
-
pull
public List<ProvisioningReport> pull(AnyType anyType, String keyColumn, List<String> columns, ConflictResolutionAction conflictResolutionAction, String inboundCorrelationRule, Connector connector, PullTaskTO pullTaskTO, String executor) throws JobExecutionException - Specified by:
pullin interfaceSyncopeStreamPullExecutor- Throws:
JobExecutionException
-
buildRealmHandler
-
buildAnyObjectHandler
-
buildUserHandler
-
buildGroupHandler
-
getInboundActions
-
setGroupOwners
protected void setGroupOwners() -
setLatestSyncToken
- Specified by:
setLatestSyncTokenin interfaceSyncopePullExecutor
-
reportHandled
- Specified by:
reportHandledin interfaceSyncopePullExecutor
-