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

Class DefaultJobManager

java.lang.Object

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

All Implemented Interfaces:

SyncopeCoreLoader, JobManager, Ordered

public class DefaultJobManager
extends Object
implements JobManager, SyncopeCoreLoader

Field Summary

Fields

Modifier and Type	Field	Description
protected final ConfParamOps	confParamOps
protected final DomainHolder<?>	domainHolder
protected final ImplementationDAO	implementationDAO
protected final JobStatusDAO	jobStatusDAO
protected static final Logger	LOG
protected final ReportDAO	reportDAO
protected final SyncopeTaskScheduler	scheduler
protected final SecurityProperties	securityProperties
protected final TaskDAO	taskDAO
protected final TaskUtilsFactory	taskUtilsFactory

Fields inherited from interface org.apache.syncope.core.provisioning.api.job.JobManager

DELEGATE_IMPLEMENTATION, NOTIFICATION_JOB, REPORT_KEY, TASK_KEY, TASK_TYPE

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor	Description
DefaultJobManager(DomainHolder<?> domainHolder, SyncopeTaskScheduler scheduler, JobStatusDAO jobStatusDAO, TaskDAO taskDAO, ReportDAO reportDAO, ImplementationDAO implementationDAO, TaskUtilsFactory taskUtilsFactory, ConfParamOps confParamOps, SecurityProperties securityProperties)

Method Summary

Modifier and Type	Method	Description
void	execute(Report report, OffsetDateTime startAt, String executor, boolean dryRun)
void	execute(SchedTask task, OffsetDateTime startAt, String executor, boolean dryRun, Map<String,Object> jobData)
int	getOrder()
boolean	isRunning(String jobName)
void	load(String domain)	Perform init operations on the given domain.
protected void	register(String domain, Report report, String cronExpression, OffsetDateTime startAt, String executor, boolean dryRun)
protected void	register(String domain, SchedTask task, String cronExpression, OffsetDateTime startAt, String executor, boolean dryRun, Map<String,Object> jobData)
void	register(Report report, String executor)
void	register(SchedTask task, String executor)
protected void	registerJob(JobExecutionContext context, Class<? extends Job> jobClass, String cronExpression, OffsetDateTime startAt)
void	unload(String domain)	Perform dispose operations on the given domain.
void	unregister(Report report)
void	unregister(Task<?> task)
protected void	unregisterJob(String jobName)

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.persistence.api.SyncopeCoreLoader

load, unload

Field Details

LOG

protected static final Logger LOG

domainHolder

protected final DomainHolder<?> domainHolder

scheduler

protected final SyncopeTaskScheduler scheduler

jobStatusDAO

protected final JobStatusDAO jobStatusDAO

taskDAO

protected final TaskDAO taskDAO

reportDAO

protected final ReportDAO reportDAO

implementationDAO

protected final ImplementationDAO implementationDAO

taskUtilsFactory

protected final TaskUtilsFactory taskUtilsFactory

confParamOps

protected final ConfParamOps confParamOps

securityProperties

protected final SecurityProperties securityProperties

Constructor Details

DefaultJobManager

public DefaultJobManager(DomainHolder<?> domainHolder,
 SyncopeTaskScheduler scheduler,
 JobStatusDAO jobStatusDAO,
 TaskDAO taskDAO,
 ReportDAO reportDAO,
 ImplementationDAO implementationDAO,
 TaskUtilsFactory taskUtilsFactory,
 ConfParamOps confParamOps,
 SecurityProperties securityProperties)

Method Details

isRunning

public boolean isRunning(String jobName)

Specified by:

isRunning in interface JobManager

registerJob

protected void registerJob(JobExecutionContext context,
 Class<? extends Job> jobClass,
 String cronExpression,
 OffsetDateTime startAt)

register

protected void register(String domain,
 SchedTask task,
 String cronExpression,
 OffsetDateTime startAt,
 String executor,
 boolean dryRun,
 Map<String,Object> jobData)

execute

public void execute(SchedTask task,
 OffsetDateTime startAt,
 String executor,
 boolean dryRun,
 Map<String,Object> jobData)

Specified by:

execute in interface JobManager

register

public void register(SchedTask task,
 String executor)

Specified by:

register in interface JobManager

register

protected void register(String domain,
 Report report,
 String cronExpression,
 OffsetDateTime startAt,
 String executor,
 boolean dryRun)

execute

public void execute(Report report,
 OffsetDateTime startAt,
 String executor,
 boolean dryRun)

Specified by:

execute in interface JobManager

register

public void register(Report report,
 String executor)

Specified by:

register in interface JobManager

unregisterJob

protected void unregisterJob(String jobName)

unregister

public void unregister(Task<?> task)

Specified by:

unregister in interface JobManager

unregister

public void unregister(Report report)

Specified by:

unregister in interface JobManager

getOrder

public int getOrder()

Specified by:

getOrder in interface Ordered

load

@Transactional
public void load(String domain)

Description copied from interface: SyncopeCoreLoader

Perform init operations on the given domain.

Specified by:

load in interface SyncopeCoreLoader

Parameters:

domain - domain to initialize

unload

public void unload(String domain)

Description copied from interface: SyncopeCoreLoader

Perform dispose operations on the given domain.

Specified by:

unload in interface SyncopeCoreLoader

Parameters:

domain - domain to unload