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

Class PushJobDelegate

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

All Implemented Interfaces:

JobDelegate, SchedTaskJobDelegate, SyncopePushExecutor

Direct Known Subclasses:

SinglePushJobDelegate, StreamPushJobDelegate

public class PushJobDelegate
extends AbstractProvisioningJobDelegate<PushTask>
implements SyncopePushExecutor

Field Summary

Fields

Modifier and Type	Field	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

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

Method Summary

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

Field Detail

searchDAO

@Autowired
protected AnySearchDAO searchDAO

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

public void reportHandled(String anyType,
                          String key)

Specified by:

reportHandled in interface SyncopePushExecutor

wasInterruptRequested

public boolean wasInterruptRequested()

Specified by:

wasInterruptRequested in interface SyncopePushExecutor

setInterrupted

public void setInterrupted()

Specified by:

setInterrupted in interface SyncopePushExecutor

doHandle

protected boolean doHandle(List<? extends Any<?>> anys,
                           PushResultHandlerDispatcher dispatcher,
                           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,
                                       String executor,
                                       org.quartz.JobExecutionContext context)
                                throws org.quartz.JobExecutionException

Specified by:

doExecuteProvisioning in class AbstractProvisioningJobDelegate<PushTask>

Throws:

org.quartz.JobExecutionException