Class ScheduledTaskDispatcher

java.lang.Object

org.chenile.scheduler.launcher.ScheduledTaskDispatcher

public class ScheduledTaskDispatcher
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final String	defaultLauncher
private final SchedulerExecutionStore	executionStore
private final Map<String, ScheduledTaskLauncher>	launchers
private static final org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor	Description
ScheduledTaskDispatcher(Map<String, ScheduledTaskLauncher> launchers, SchedulerExecutionStore executionStore, String defaultLauncher)

Method Summary

Modifier and Type	Method	Description
private void	applyDefaults(SchedulerInfo schedulerInfo)
void	dispatch(SchedulerInfo schedulerInfo, ChenileServiceDefinition serviceDefinition, OperationDefinition operationDefinition, Date scheduledFireTime, Date actualFireTime)
private int	effectiveRetryCount(SchedulerInfo info)
private void	launchOnce(ScheduledTaskLauncher launcher, ScheduledExecutionRequest request)
private void	launchWithLocalRetries(ScheduledTaskLauncher launcher, ScheduledExecutionRequest request)
private LaunchResult	launchWithOptionalTimeout(ScheduledTaskLauncher launcher, ScheduledExecutionRequest request)
private String	normalize(String value)
private ScheduledExecutionRequest	request(SchedulerInfo schedulerInfo, ChenileServiceDefinition serviceDefinition, OperationDefinition operationDefinition, Date scheduledFireTime, Date actualFireTime)
private Instant	toInstant(Date date)

Methods inherited from class Object

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

Field Details

logger

private static final org.slf4j.Logger logger

launchers

private final Map<String, ScheduledTaskLauncher> launchers

executionStore

private final SchedulerExecutionStore executionStore

defaultLauncher

private final String defaultLauncher

Constructor Details

ScheduledTaskDispatcher

public ScheduledTaskDispatcher(Map<String, ScheduledTaskLauncher> launchers,
 SchedulerExecutionStore executionStore,
 String defaultLauncher)

Method Details

dispatch

public void dispatch(SchedulerInfo schedulerInfo,
 ChenileServiceDefinition serviceDefinition,
 OperationDefinition operationDefinition,
 Date scheduledFireTime,
 Date actualFireTime)
              throws Exception

Throws:

Exception

launchWithLocalRetries

private void launchWithLocalRetries(ScheduledTaskLauncher launcher,
 ScheduledExecutionRequest request)
                             throws Exception

Throws:

Exception

launchOnce

private void launchOnce(ScheduledTaskLauncher launcher,
 ScheduledExecutionRequest request)
                 throws Exception

Throws:

Exception

launchWithOptionalTimeout

private LaunchResult launchWithOptionalTimeout(ScheduledTaskLauncher launcher,
 ScheduledExecutionRequest request)
                                        throws Exception

Throws:

Exception

request

private ScheduledExecutionRequest request(SchedulerInfo schedulerInfo,
 ChenileServiceDefinition serviceDefinition,
 OperationDefinition operationDefinition,
 Date scheduledFireTime,
 Date actualFireTime)

toInstant

private Instant toInstant(Date date)

applyDefaults

private void applyDefaults(SchedulerInfo schedulerInfo)

effectiveRetryCount

private int effectiveRetryCount(SchedulerInfo info)

normalize

private String normalize(String value)