Class StreamPushJobDelegate
java.lang.Object
org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate<PushTask>
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,StoppableJobDelegate,SyncopeStreamPushExecutor,SyncopePushExecutor
-
Field Summary
Fields inherited from class org.apache.syncope.core.provisioning.java.pushpull.PushJobDelegate
dispatcher, handled, perContextActions, profile, realmSearchDAO, searchCondVisitor, searchDAOFields 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 AnyObjectPushResultHandlerprotected GroupPushResultHandlerprotected UserPushResultHandlerpush(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, doExecute, doHandle, getPushActions, init, reportHandled, 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, setStatus
-
Constructor Details
-
StreamPushJobDelegate
public StreamPushJobDelegate()
-
-
Method Details
-
buildAnyObjectHandler
- Overrides:
buildAnyObjectHandlerin classPushJobDelegate
-
buildUserHandler
- Overrides:
buildUserHandlerin classPushJobDelegate
-
buildGroupHandler
- Overrides:
buildGroupHandlerin 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 JobExecutionException - Specified by:
pushin interfaceSyncopeStreamPushExecutor- Throws:
JobExecutionException
-