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

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

public class StreamPushJobDelegate
extends PushJobDelegate
implements SyncopeStreamPushExecutor

Field Summary

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

dispatcher, handled, perContextActions, profile, realmSearchDAO, searchCondVisitor, searchDAO

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

Method Summary

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, doExecute, doHandle, getPushActions, init, reportHandled, 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

Constructor Details

StreamPushJobDelegate

public StreamPushJobDelegate()

Method Details

buildAnyObjectHandler

protected AnyObjectPushResultHandler buildAnyObjectHandler()

Overrides:

buildAnyObjectHandler in class PushJobDelegate

buildUserHandler

protected UserPushResultHandler buildUserHandler()

Overrides:

buildUserHandler in class PushJobDelegate

buildGroupHandler

protected GroupPushResultHandler buildGroupHandler()

Overrides:

buildGroupHandler in class PushJobDelegate

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:

push in interface SyncopeStreamPushExecutor

Throws:

JobExecutionException