Class StreamPushJobDelegate
- java.lang.Object
-
- org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate<T>
-
- org.apache.syncope.core.provisioning.java.pushpull.AbstractProvisioningJobDelegate<PushTask>
-
- org.apache.syncope.core.provisioning.java.pushpull.PushJobDelegate
-
- org.apache.syncope.core.provisioning.java.pushpull.stream.StreamPushJobDelegate
-
- All Implemented Interfaces:
JobDelegate
,SchedTaskJobDelegate
,SyncopeStreamPushExecutor
,SyncopePushExecutor
public class StreamPushJobDelegate extends PushJobDelegate implements SyncopeStreamPushExecutor
-
-
Field Summary
-
Fields inherited from class org.apache.syncope.core.provisioning.java.pushpull.PushJobDelegate
anyUtilsFactory, handled, perContextActions, profile, realmDAO, searchCondVisitor, searchDAO
-
Fields inherited from class org.apache.syncope.core.provisioning.java.pushpull.AbstractProvisioningJobDelegate
anyTypeDAO, connectorManager, entityFactory, perContextProvisionSorter, policyDAO, resourceDAO
-
Fields inherited from class org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate
auditManager, interrupt, interrupted, LOG, notificationManager, publisher, securityProperties, task, taskDAO, taskDataBinder, taskExecDAO, taskType, taskUtilsFactory
-
Fields inherited from interface org.apache.syncope.core.provisioning.api.job.JobDelegate
OPERATION_ID
-
-
Constructor Summary
Constructors Constructor Description StreamPushJobDelegate()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected AnyObjectPushResultHandler
buildAnyObjectHandler()
protected GroupPushResultHandler
buildGroupHandler()
protected UserPushResultHandler
buildUserHandler()
List<ProvisioningReport>
push(AnyType anyType, List<? extends Any<?>> anys, List<String> columns, Connector connector, List<String> propagationActions, PushTaskTO pushTaskTO, String executor)
-
Methods inherited from class org.apache.syncope.core.provisioning.java.pushpull.PushJobDelegate
buildRealmHandler, doExecuteProvisioning, doHandle, getPushActions, reportHandled, setInterrupted, 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
-
-
-
-
Method Detail
-
buildAnyObjectHandler
protected AnyObjectPushResultHandler buildAnyObjectHandler()
- Overrides:
buildAnyObjectHandler
in classPushJobDelegate
-
buildUserHandler
protected UserPushResultHandler buildUserHandler()
- Overrides:
buildUserHandler
in classPushJobDelegate
-
buildGroupHandler
protected GroupPushResultHandler buildGroupHandler()
- Overrides:
buildGroupHandler
in classPushJobDelegate
-
push
public List<ProvisioningReport> push(AnyType anyType, List<? extends Any<?>> anys, List<String> columns, Connector connector, List<String> propagationActions, PushTaskTO pushTaskTO, String executor) throws org.quartz.JobExecutionException
- Specified by:
push
in interfaceSyncopeStreamPushExecutor
- Throws:
org.quartz.JobExecutionException
-
-