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

Class StreamPullJobDelegate

java.lang.Object

org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate

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, SyncopeStreamPullExecutor, SyncopePullExecutor

public class StreamPullJobDelegate
extends PullJobDelegate
implements SyncopeStreamPullExecutor

Field Summary

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

anyUtilsFactory, groupDAO, handled, inboundMatcher, latestSyncTokens, perContextActions, perContextReconFilterBuilder, profile, validator, virSchemaDAO

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

adminUser, anyTypeDAO, connFactory, perContextProvisionSorter, policyDAO, resourceDAO

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

auditManager, entityFactory, interrupt, interrupted, LOG, notificationManager, publisher, task, taskDAO, taskDataBinder, taskExecDAO

Constructor Summary

Constructors

Constructor and Description
StreamPullJobDelegate()

Method Summary

Modifier and Type	Method and Description
List<ProvisioningReport>	pull(AnyType anyType, String keyColumn, List<String> columns, ConflictResolutionAction conflictResolutionAction, String pullCorrelationRule, Connector connector, PullTaskTO pullTaskTO)

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

buildAnyObjectHandler, buildGroupHandler, buildRealmHandler, buildUserHandler, doExecuteProvisioning, getPullActions, getReconFilterBuilder, reportHandled, setGroupOwners, setInterrupted, setLatestSyncToken, wasInterruptRequested

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

createReport, doExecute, generate, getConnector, getProvisionSorter, getTaskClassReference, hasToBeRegistered

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

execute, interrupt, isInterrupted, register, setStatus

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamPullJobDelegate

public StreamPullJobDelegate()

Method Detail

pull

public List<ProvisioningReport> pull(AnyType anyType,
                                     String keyColumn,
                                     List<String> columns,
                                     ConflictResolutionAction conflictResolutionAction,
                                     String pullCorrelationRule,
                                     Connector connector,
                                     PullTaskTO pullTaskTO)
                              throws org.quartz.JobExecutionException

Specified by:

pull in interface SyncopeStreamPullExecutor

Throws:

org.quartz.JobExecutionException