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

Class PushJobDelegate

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

All Implemented Interfaces:

SchedTaskJobDelegate, StoppableSchedTaskJobDelegate, SyncopePushExecutor

Direct Known Subclasses:

SinglePushJobDelegate, StreamPushJobDelegate

public class PushJobDelegate
extends AbstractProvisioningJobDelegate<PushTask>
implements SyncopePushExecutor, StoppableSchedTaskJobDelegate

Field Summary

Fields

Modifier and Type	Field	Description
protected PushResultHandlerDispatcher	dispatcher
protected final Map<String,MutablePair<Integer,String>>	handled
protected final Map<String,PushActions>	perContextActions
protected ProvisioningProfile<PushTask,PushActions>	profile
protected RealmSearchDAO	realmSearchDAO
protected SearchCondVisitor	searchCondVisitor
protected AnySearchDAO	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
PushJobDelegate()

Method Summary

Modifier and Type	Method	Description
protected AnyObjectPushResultHandler	buildAnyObjectHandler()
protected GroupPushResultHandler	buildGroupHandler()
protected RealmPushResultHandler	buildRealmHandler()
protected UserPushResultHandler	buildUserHandler()
protected String	doExecute(JobExecutionContext context)	The actual execution, delegated to child classes.
protected boolean	doHandle(List<? extends Any<?>> anys, PushResultHandlerDispatcher dispatcher, ExternalResource resource)
protected List<PushActions>	getPushActions(List<? extends Implementation> impls)
protected void	init(TaskType taskType, String taskKey, JobExecutionContext context)
void	reportHandled(String anyType, String key)
void	stop()	Request the current Job to stop the execution of the running Task.

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

Methods inherited from interface org.apache.syncope.core.provisioning.api.job.SchedTaskJobDelegate

execute

Field Details

searchDAO

@Autowired
protected AnySearchDAO searchDAO

realmSearchDAO

@Autowired
protected RealmSearchDAO realmSearchDAO

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

dispatcher

protected PushResultHandlerDispatcher dispatcher

Constructor Details

PushJobDelegate

public PushJobDelegate()

Method Details

reportHandled

public void reportHandled(String anyType,
 String key)

Specified by:

reportHandled in interface SyncopePushExecutor

doHandle

protected boolean doHandle(List<? extends Any<?>> anys,
 PushResultHandlerDispatcher dispatcher,
 ExternalResource resource)
                    throws JobExecutionException

Throws:

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)

init

protected void init(TaskType taskType,
 String taskKey,
 JobExecutionContext context)
             throws JobExecutionException

Overrides:

init in class AbstractProvisioningJobDelegate<PushTask>

Throws:

JobExecutionException

stop

public void stop()

Description copied from interface: StoppableSchedTaskJobDelegate

Request the current Job to stop the execution of the running Task.

Specified by:

stop in interface StoppableSchedTaskJobDelegate

doExecute

protected String doExecute(JobExecutionContext context)
                    throws JobExecutionException

Description copied from class: AbstractSchedTaskJobDelegate

The actual execution, delegated to child classes.

Specified by:

doExecute in class AbstractSchedTaskJobDelegate<PushTask>

Parameters:

context - job execution context, can be used to pass parameters to the job

Returns:

the task execution status to be set

Throws:

JobExecutionException - if anything goes wrong