Package ch.tocco.nice2.tasks.impl.quartz

Class TaskSchedulingServiceImpl

java.lang.Object

ch.tocco.nice2.tasks.impl.quartz.TaskSchedulingServiceImpl

All Implemented Interfaces:

TaskSchedulingService

@Component
public class TaskSchedulingServiceImpl
extends Object
implements TaskSchedulingService

Field Summary

Fields inherited from interface ch.tocco.nice2.tasks.api.quartz.TaskSchedulingService

HIGH_LISTENER_PRIORITY, LOW_LISTENER_PRIORITY, NORMAL_LISTENER_PRIORITY

Constructor Summary

Constructors

Constructor	Description
TaskSchedulingServiceImpl(L10N l10n, org.quartz.Scheduler scheduler, ProgressPersistenceManager progressPersistenceManager, SecurityManager securityManager)

Method Summary

Modifier and Type	Method	Description
void	cancelJob(Entity taskExecution)	Interrupt a running job.
void	cancelJob(org.quartz.JobKey jobKey)	Interrupt a running job.
protected void	checkAccess(org.quartz.JobKey jobKey)
Optional<org.quartz.JobKey>	executeJobImmediately(Class<? extends AbstractJob> jobClass, String taskName, CallableType taskType, JobDataMapBuilder jobData)	Schedule a task which will be executed immediately (unless all threads are already occupied).
void	removeScheduledJob(Entity taskExecution)	Remove a scheduled job.
void	rescheduleJob(Entity taskExecution, org.joda.time.DateTime newDate)	Change the scheduled start time of a given job.
Optional<org.quartz.JobKey>	scheduleJob(Class<? extends AbstractJob> jobClass, String taskName, CallableType taskType, JobDataMapBuilder jobData, org.joda.time.DateTime executionDate)	Schedule a task to be executed at a specific date and time.
void	setBatchJobContributions(List<BatchJobContribution> contributions)
void	setConverters(List<com.thoughtworks.xstream.converters.Converter> converters)

Methods inherited from class java.lang.Object

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

Constructor Details

TaskSchedulingServiceImpl

public TaskSchedulingServiceImpl(L10N l10n,
 org.quartz.Scheduler scheduler,
 ProgressPersistenceManager progressPersistenceManager,
 SecurityManager securityManager)

Method Details

setBatchJobContributions

public void setBatchJobContributions(List<BatchJobContribution> contributions)

setConverters

@Autowired
public void setConverters(List<com.thoughtworks.xstream.converters.Converter> converters)

executeJobImmediately

public Optional<org.quartz.JobKey> executeJobImmediately(Class<? extends AbstractJob> jobClass,
 String taskName,
 CallableType taskType,
 JobDataMapBuilder jobData)

Description copied from interface: TaskSchedulingService

Schedule a task which will be executed immediately (unless all threads are already occupied).

Specified by:

executeJobImmediately in interface TaskSchedulingService

Returns:

the JobKey if new job was scheduled (no new job is created if multiple schedules are disabled by setting JobDataMapBuilder.putMultipleSchedulesEnabled(boolean) to `false` and a job with the given `taskName` already exists)

scheduleJob

public Optional<org.quartz.JobKey> scheduleJob(Class<? extends AbstractJob> jobClass,
 String taskName,
 CallableType taskType,
 JobDataMapBuilder jobData,
 org.joda.time.DateTime executionDate)

Description copied from interface: TaskSchedulingService

Schedule a task to be executed at a specific date and time.

Specified by:

scheduleJob in interface TaskSchedulingService

Returns:

the JobKey if new job was scheduled (no new job is created if multiple schedules are disabled by setting JobDataMapBuilder.putMultipleSchedulesEnabled(boolean) to `false` and a job with the given `taskName` already exists)

cancelJob

public void cancelJob(org.quartz.JobKey jobKey)

Description copied from interface: TaskSchedulingService

Interrupt a running job. The job must extend from AbstractInterruptableJob and must properly implement the cancellation.

Specified by:

cancelJob in interface TaskSchedulingService

Parameters:

jobKey - the key of the job

cancelJob

public void cancelJob(Entity taskExecution)

Description copied from interface: TaskSchedulingService

Interrupt a running job. The job must extend from AbstractInterruptableJob and must properly implement the cancellation.

Specified by:

cancelJob in interface TaskSchedulingService

Parameters:

taskExecution - the 'Task_execution' entity that represents the job to cancel

removeScheduledJob

public void removeScheduledJob(Entity taskExecution)

Description copied from interface: TaskSchedulingService

Remove a scheduled job.

Specified by:

removeScheduledJob in interface TaskSchedulingService

Parameters:

taskExecution - the 'Task_execution' entity that represents the job to delete

rescheduleJob

public void rescheduleJob(Entity taskExecution,
 org.joda.time.DateTime newDate)

Description copied from interface: TaskSchedulingService

Change the scheduled start time of a given job.

Specified by:

rescheduleJob in interface TaskSchedulingService

Parameters:

taskExecution - the 'Task_execution' entity that represents the job to reschedule

checkAccess

protected void checkAccess(org.quartz.JobKey jobKey)