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

Class LiveSyncJobDelegate

java.lang.Object

org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate<LiveSyncTask>

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

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

All Implemented Interfaces:

SchedTaskJobDelegate, StoppableSchedTaskJobDelegate

public class LiveSyncJobDelegate
extends AbstractProvisioningJobDelegate<LiveSyncTask>
implements StoppableSchedTaskJobDelegate

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static final record	LiveSyncJobDelegate.LiveSyncInfo

Field Summary

Fields

Modifier and Type	Field	Description
protected GroupDAO	groupDAO
protected InboundMatcher	inboundMatcher
protected List<LiveSyncJobDelegate.LiveSyncInfo>	infos
protected LiveSyncTaskExecSaver	liveSyncTaskExecSaver
protected LiveSyncDeltaMapper	mapper
protected final Map<String,InboundActions>	perContextActions
protected PlainSchemaDAO	plainSchemaDAO
protected ProvisioningProfile<PullTask,InboundActions>	profile
protected boolean	stopRequested
protected PlainAttrValidationManager	validator
protected VirSchemaDAO	virSchemaDAO

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

Method Summary

Modifier and Type	Method	Description
protected AnyObjectPullResultHandler	buildAnyObjectHandler()
protected GroupPullResultHandler	buildGroupHandler()
protected RealmPullResultHandler	buildRealmHandler()
protected UserPullResultHandler	buildUserHandler()
protected String	doExecute(JobExecutionContext context)	The actual execution, delegated to child classes.
void	execute(TaskType taskType, String taskKey, JobExecutionContext context)	Executes a Job to run the given Task.
protected void	init(TaskType taskType, String taskKey, JobExecutionContext context)
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, initExecution, register, setStatus

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

plainSchemaDAO

@Autowired
protected PlainSchemaDAO plainSchemaDAO

virSchemaDAO

@Autowired
protected VirSchemaDAO virSchemaDAO

groupDAO

@Autowired
protected GroupDAO groupDAO

validator

@Autowired
protected PlainAttrValidationManager validator

inboundMatcher

@Autowired
protected InboundMatcher inboundMatcher

liveSyncTaskExecSaver

@Autowired
protected LiveSyncTaskExecSaver liveSyncTaskExecSaver

profile

protected ProvisioningProfile<PullTask,InboundActions> profile

mapper

protected LiveSyncDeltaMapper mapper

infos

protected List<LiveSyncJobDelegate.LiveSyncInfo> infos

perContextActions

protected final Map<String,InboundActions> perContextActions

stopRequested

protected volatile boolean stopRequested

Constructor Details

LiveSyncJobDelegate

public LiveSyncJobDelegate()

Method Details

buildRealmHandler

protected RealmPullResultHandler buildRealmHandler()

buildAnyObjectHandler

protected AnyObjectPullResultHandler buildAnyObjectHandler()

buildUserHandler

protected UserPullResultHandler buildUserHandler()

buildGroupHandler

protected GroupPullResultHandler buildGroupHandler()

init

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

Overrides:

init in class AbstractProvisioningJobDelegate<LiveSyncTask>

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

execute

@Transactional
public void execute(TaskType taskType,
 String taskKey,
 JobExecutionContext context)
             throws JobExecutionException

Description copied from interface: SchedTaskJobDelegate

Executes a Job to run the given Task.

Specified by:

execute in interface SchedTaskJobDelegate

Overrides:

execute in class AbstractSchedTaskJobDelegate<LiveSyncTask>

Parameters:

taskType - Type of task to run

taskKey - Task key to run

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

Throws:

JobExecutionException - if anything goes wrong

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<LiveSyncTask>

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