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

Class SyncopeTaskScheduler

java.lang.Object

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

public class SyncopeTaskScheduler
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<Pair<String,String>,Pair<Job,ScheduledFuture<?>>>	jobs
protected final JobStatusDAO	jobStatusDAO
protected static final Logger	LOG
protected final TaskScheduler	scheduler

Constructor Summary

Constructors

Constructor	Description
SyncopeTaskScheduler(TaskScheduler scheduler, JobStatusDAO jobStatusDAO)

Method Summary

Modifier and Type	Method	Description
void	cancel(String domain, String jobName)
boolean	contains(String domain, String jobName)
void	delete(String domain, String jobName)
Optional<Class<?>>	getJobClass(String domain, String jobName)
List<String>	getJobNames(String domain)
Optional<OffsetDateTime>	getNextTrigger(String domain, String jobName)
void	register(Job job)
void	schedule(Job job, Instant startTime)
void	schedule(Job job, CronTrigger trigger)
void	start(String domain, String jobName)
void	start(Job job)

Methods inherited from class java.lang.Object

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

Field Details

LOG

protected static final Logger LOG

scheduler

protected final TaskScheduler scheduler

jobStatusDAO

protected final JobStatusDAO jobStatusDAO

jobs

protected final Map<Pair<String,String>,Pair<Job,ScheduledFuture<?>>> jobs

Constructor Details

SyncopeTaskScheduler

public SyncopeTaskScheduler(TaskScheduler scheduler,
 JobStatusDAO jobStatusDAO)

Method Details

register

public void register(Job job)

start

public void start(String domain,
 String jobName)

start

public void start(Job job)

schedule

public void schedule(Job job,
 CronTrigger trigger)

schedule

public void schedule(Job job,
 Instant startTime)

contains

public boolean contains(String domain,
 String jobName)

getJobClass

public Optional<Class<?>> getJobClass(String domain,
 String jobName)

getNextTrigger

public Optional<OffsetDateTime> getNextTrigger(String domain,
 String jobName)

cancel

public void cancel(String domain,
 String jobName)

delete

public void delete(String domain,
 String jobName)

getJobNames

public List<String> getJobNames(String domain)