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

Class PushJobDelegate

java.lang.Object

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

org.apache.syncope.core.provisioning.java.pushpull.AbstractProvisioningJobDelegate<PushTask>

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

All Implemented Interfaces:

JobDelegate, SchedTaskJobDelegate

Direct Known Subclasses:

SinglePushJobDelegate, StreamPushJobDelegate

public class PushJobDelegate
extends AbstractProvisioningJobDelegate<PushTask>

Field Summary

Fields

Modifier and Type	Field and Description
protected AnyUtilsFactory	anyUtilsFactory
protected Map<String,MutablePair<Integer,String>>	handled
protected Map<String,PushActions>	perContextActions
protected ProvisioningProfile<PushTask,PushActions>	profile
protected RealmDAO	realmDAO
protected SearchCondVisitor	searchCondVisitor
protected AnySearchDAO	searchDAO Search DAO.

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

Method Summary

Modifier and Type	Method and Description
protected AnyObjectPushResultHandler	buildAnyObjectHandler()
protected GroupPushResultHandler	buildGroupHandler()
protected RealmPushResultHandler	buildRealmHandler()
protected UserPushResultHandler	buildUserHandler()
protected String	doExecuteProvisioning(PushTask pushTask, Connector connector, boolean dryRun, org.quartz.JobExecutionContext context)
protected void	doHandle(List<? extends Any<?>> anys, SyncopePushResultHandler handler, ExternalResource resource)
protected List<PushActions>	getPushActions(List<? extends Implementation> impls)
protected void	reportHandled(String anyType, String key)

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

Field Detail

searchDAO

@Autowired
protected AnySearchDAO searchDAO

Search DAO.

realmDAO

@Autowired
protected RealmDAO realmDAO

anyUtilsFactory

@Autowired
protected AnyUtilsFactory anyUtilsFactory

searchCondVisitor

@Autowired
protected SearchCondVisitor searchCondVisitor

profile

protected ProvisioningProfile<PushTask,PushActions> profile

handled

protected final Map<String,MutablePair<Integer,String>> handled

perContextActions

protected final Map<String,PushActions> perContextActions

Constructor Detail

PushJobDelegate

public PushJobDelegate()

Method Detail

reportHandled

protected void reportHandled(String anyType,
                             String key)

doHandle

protected void doHandle(List<? extends Any<?>> anys,
                        SyncopePushResultHandler handler,
                        ExternalResource resource)
                 throws org.quartz.JobExecutionException

Throws:

org.quartz.JobExecutionException

buildRealmHandler

protected RealmPushResultHandler buildRealmHandler()

buildAnyObjectHandler

protected AnyObjectPushResultHandler buildAnyObjectHandler()

buildUserHandler

protected UserPushResultHandler buildUserHandler()

buildGroupHandler

protected GroupPushResultHandler buildGroupHandler()

getPushActions

protected List<PushActions> getPushActions(List<? extends Implementation> impls)

doExecuteProvisioning

protected String doExecuteProvisioning(PushTask pushTask,
                                       Connector connector,
                                       boolean dryRun,
                                       org.quartz.JobExecutionContext context)
                                throws org.quartz.JobExecutionException

Specified by:

doExecuteProvisioning in class AbstractProvisioningJobDelegate<PushTask>

Throws:

org.quartz.JobExecutionException