Class ScheduledTaskDispatcher
java.lang.Object
org.chenile.scheduler.launcher.ScheduledTaskDispatcher
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final Stringprivate final SchedulerExecutionStoreprivate final Map<String, ScheduledTaskLauncher> private static final org.slf4j.Logger -
Constructor Summary
ConstructorsConstructorDescriptionScheduledTaskDispatcher(Map<String, ScheduledTaskLauncher> launchers, SchedulerExecutionStore executionStore, String defaultLauncher) -
Method Summary
Modifier and TypeMethodDescriptionprivate voidapplyDefaults(SchedulerInfo schedulerInfo) voiddispatch(SchedulerInfo schedulerInfo, ChenileServiceDefinition serviceDefinition, OperationDefinition operationDefinition, Date scheduledFireTime, Date actualFireTime) private intprivate voidlaunchOnce(ScheduledTaskLauncher launcher, ScheduledExecutionRequest request) private voidlaunchWithLocalRetries(ScheduledTaskLauncher launcher, ScheduledExecutionRequest request) private LaunchResultlaunchWithOptionalTimeout(ScheduledTaskLauncher launcher, ScheduledExecutionRequest request) private Stringprivate ScheduledExecutionRequestrequest(SchedulerInfo schedulerInfo, ChenileServiceDefinition serviceDefinition, OperationDefinition operationDefinition, Date scheduledFireTime, Date actualFireTime) private Instant
-
Field Details
-
logger
private static final org.slf4j.Logger logger -
launchers
-
executionStore
-
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
-
applyDefaults
-
effectiveRetryCount
-
normalize
-