Package com.flowable.core.service.async.timer

Class CoreTimerJobScheduler

java.lang.Object

com.flowable.core.service.async.timer.CoreTimerJobScheduler

All Implemented Interfaces:

TimerJobScheduler

public class CoreTimerJobScheduler
extends Object
implements TimerJobScheduler

Author:

Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
protected final TimerJobScheduler	defaultTimerJobScheduler
protected final JobServiceConfiguration	jobServiceConfiguration
protected final org.slf4j.Logger	logger
protected final Supplier<VariableServiceConfiguration>	variableServiceConfigurationSupplier

Constructor Summary

Constructors

Constructor	Description
CoreTimerJobScheduler(TimerJobScheduler defaultTimerJobScheduler, JobServiceConfiguration jobServiceConfiguration, Supplier<VariableServiceConfiguration> variableServiceConfigurationSupplier)

Method Summary

Modifier and Type	Method	Description
protected String	findJobElementId(JobEntity job)
protected VariableInstanceEntity	findTimerJobConfiguration(String scopeId, String scopeType, String elementId)
protected VariableInstanceEntity	findTimerJobConfiguration(JobEntity job)
void	rescheduleTimerJobAfterExecution(JobEntity timerJob, VariableScope variableScope)
void	scheduleTimerJob(TimerJobEntity timerJob)
protected boolean	shouldStopTimerRepetition(JobEntity job)

Methods inherited from class java.lang.Object

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

Field Details

defaultTimerJobScheduler

protected final TimerJobScheduler defaultTimerJobScheduler

jobServiceConfiguration

protected final JobServiceConfiguration jobServiceConfiguration

variableServiceConfigurationSupplier

protected final Supplier<VariableServiceConfiguration> variableServiceConfigurationSupplier

logger

protected final org.slf4j.Logger logger

Constructor Details

CoreTimerJobScheduler

public CoreTimerJobScheduler(TimerJobScheduler defaultTimerJobScheduler,
 JobServiceConfiguration jobServiceConfiguration,
 Supplier<VariableServiceConfiguration> variableServiceConfigurationSupplier)

Method Details

rescheduleTimerJobAfterExecution

public void rescheduleTimerJobAfterExecution(JobEntity timerJob,
 VariableScope variableScope)

Specified by:

rescheduleTimerJobAfterExecution in interface TimerJobScheduler

shouldStopTimerRepetition

protected boolean shouldStopTimerRepetition(JobEntity job)

findTimerJobConfiguration

protected VariableInstanceEntity findTimerJobConfiguration(JobEntity job)

findTimerJobConfiguration

protected VariableInstanceEntity findTimerJobConfiguration(String scopeId,
 String scopeType,
 String elementId)

findJobElementId

protected String findJobElementId(JobEntity job)

scheduleTimerJob

public void scheduleTimerJob(TimerJobEntity timerJob)

Specified by:

scheduleTimerJob in interface TimerJobScheduler