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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static final record	SyncopeTaskScheduler.Key
protected static final record	SyncopeTaskScheduler.Value

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CACHE
protected final Map<SyncopeTaskScheduler.Key,SyncopeTaskScheduler.Value>	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	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)
protected void	register(Job job, ScheduledFuture<?> instant, ScheduledFuture<?> cron)
void	schedule(Job job, Instant startTime)
void	schedule(Job job, CronTrigger trigger)
void	start(String domain, String jobName)
void	stop(String domain, String jobName)
protected void	stop(SyncopeTaskScheduler.Key key, List<Function<SyncopeTaskScheduler.Value,Optional<ScheduledFuture<?>>>> suppliers)

Methods inherited from class java.lang.Object

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

Field Details

CACHE

public static final String CACHE

See Also:

• Constant Field Values

LOG

protected static final Logger LOG

scheduler

protected final TaskScheduler scheduler

jobStatusDAO

protected final JobStatusDAO jobStatusDAO

jobs

protected final Map<SyncopeTaskScheduler.Key,SyncopeTaskScheduler.Value> jobs

Constructor Details

SyncopeTaskScheduler

public SyncopeTaskScheduler(TaskScheduler scheduler,
 JobStatusDAO jobStatusDAO)

Method Details

register

protected void register(Job job,
 ScheduledFuture<?> instant,
 ScheduledFuture<?> cron)

register

public void register(Job job)

schedule

public void schedule(Job job,
 Instant startTime)

schedule

public void schedule(Job job,
 CronTrigger trigger)

start

public void start(String domain,
 String jobName)

stop

protected void stop(SyncopeTaskScheduler.Key key,
 List<Function<SyncopeTaskScheduler.Value,Optional<ScheduledFuture<?>>>> suppliers)

stop

public void stop(String domain,
 String jobName)

delete

public void delete(String domain,
 String jobName)

getJobClass

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

getNextTrigger

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

getJobNames

public List<String> getJobNames(String domain)