brainslug.flow.execution.async

Class DefaultFlowStartScheduler

java.lang.Object

brainslug.flow.execution.async.DefaultFlowStartScheduler

All Implemented Interfaces:

AsyncFlowStartScheduler

public class DefaultFlowStartScheduler
extends Object
implements AsyncFlowStartScheduler

Constructor Summary

Constructors

Constructor and Description
DefaultFlowStartScheduler()

Method Summary

Modifier and Type	Method and Description
Set<brainslug.flow.execution.async.DefaultFlowStartScheduler.TimedFlowDefinition>	getFlowDefinitionsWithStartTimer(Collection<FlowDefinition> definitions)
ScheduledExecutorService	getScheduledExecutorService()
SchedulerOptions	getSchedulerOptions()
void	start(SchedulerOptions schedulerOptions, BrainslugContext brainslugContext, Collection<FlowDefinition> definitions)
void	stop()
DefaultFlowStartScheduler	withScheduledExecutorService(ScheduledExecutorService scheduledExecutorService)
DefaultFlowStartScheduler	withSchedulerOptions(SchedulerOptions schedulerOptions)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultFlowStartScheduler

public DefaultFlowStartScheduler()

Method Detail

start

public void start(SchedulerOptions schedulerOptions,
                  BrainslugContext brainslugContext,
                  Collection<FlowDefinition> definitions)

Specified by:

start in interface AsyncFlowStartScheduler

stop

public void stop()

Specified by:

stop in interface AsyncFlowStartScheduler

getFlowDefinitionsWithStartTimer

public Set<brainslug.flow.execution.async.DefaultFlowStartScheduler.TimedFlowDefinition> getFlowDefinitionsWithStartTimer(Collection<FlowDefinition> definitions)

getScheduledExecutorService

public ScheduledExecutorService getScheduledExecutorService()

withScheduledExecutorService

public DefaultFlowStartScheduler withScheduledExecutorService(ScheduledExecutorService scheduledExecutorService)

getSchedulerOptions

public SchedulerOptions getSchedulerOptions()

withSchedulerOptions

public DefaultFlowStartScheduler withSchedulerOptions(SchedulerOptions schedulerOptions)