brainslug.flow.execution.token

Class TokenFlowExecutor

java.lang.Object

brainslug.flow.execution.token.TokenFlowExecutor

All Implemented Interfaces:

FlowExecutor

public class TokenFlowExecutor
extends Object
implements FlowExecutor

Field Summary

Fields

Modifier and Type	Field and Description
protected AsyncTriggerScheduler	asyncTriggerScheduler
protected AsyncTriggerStore	asyncTriggerStore
protected CallDefinitionExecutor	callDefinitionExecutor
protected DefinitionStore	definitionStore
protected ListenerManager	listenerManager
protected PredicateEvaluator	predicateEvaluator
protected PropertyStore	propertyStore
protected Registry	registry
protected TokenStore	tokenStore

Constructor Summary

Constructors

Constructor and Description
TokenFlowExecutor(TokenStore tokenStore, DefinitionStore definitionStore, PropertyStore propertyStore, ListenerManager listenerManager, Registry registry, PredicateEvaluator predicateEvaluator, AsyncTriggerStore asyncTriggerStore, AsyncTriggerScheduler asyncTriggerScheduler, CallDefinitionExecutor callDefinitionExecutor)

Method Summary

Modifier and Type	Method and Description
protected void	addNodeExecutorMappings()
protected void	addToken(TriggerContext trigger, FlowNodeDefinition<?> node, FlowNodeDefinition nextNode)
protected TaskNodeExecutor	createTaskNodeExecutor()
protected Trigger	createTriggerContextForNextNode(TriggerContext event, FlowNodeDefinition nextNode)
protected <T extends FlowNodeDefinition> FlowNodeExecutor<T>	getNodeExecutor(T nodeDefinition)
protected FlowNodeDefinition<?>	getStartNodeDefinition(Identifier definitionId, Identifier nodeId)
void	setAsyncTriggerScheduler(AsyncTriggerScheduler asyncTriggerScheduler)
void	setAsyncTriggerStore(AsyncTriggerStore asyncTriggerStore)
void	setCallDefinitionExecutor(CallDefinitionExecutor callDefinitionExecutor)
void	setDefinitionStore(DefinitionStore definitionStore)
void	setListenerManager(ListenerManager listenerManager)
void	setPredicateEvaluator(PredicateEvaluator predicateEvaluator)
void	setPropertyStore(PropertyStore propertyStore)
void	setRegistry(Registry registry)
void	setTokenOperations(TokenOperations tokenOperations)
void	setTokenStore(TokenStore tokenStore)
Identifier	startFlow(TriggerContext trigger)
void	trigger(TriggerContext trigger)
protected void	triggerNext(TriggerContext trigger, FlowNodeDefinition<?> node, FlowNodeExecutionResult flowNodeExecutionResult)

Methods inherited from class java.lang.Object

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

Field Detail

tokenStore

protected TokenStore tokenStore

definitionStore

protected DefinitionStore definitionStore

propertyStore

protected PropertyStore propertyStore

listenerManager

protected ListenerManager listenerManager

registry

protected Registry registry

predicateEvaluator

protected PredicateEvaluator predicateEvaluator

asyncTriggerStore

protected AsyncTriggerStore asyncTriggerStore

asyncTriggerScheduler

protected AsyncTriggerScheduler asyncTriggerScheduler

callDefinitionExecutor

protected CallDefinitionExecutor callDefinitionExecutor

Constructor Detail

TokenFlowExecutor

public TokenFlowExecutor(TokenStore tokenStore,
                         DefinitionStore definitionStore,
                         PropertyStore propertyStore,
                         ListenerManager listenerManager,
                         Registry registry,
                         PredicateEvaluator predicateEvaluator,
                         AsyncTriggerStore asyncTriggerStore,
                         AsyncTriggerScheduler asyncTriggerScheduler,
                         CallDefinitionExecutor callDefinitionExecutor)

Method Detail

addNodeExecutorMappings

protected void addNodeExecutorMappings()

createTaskNodeExecutor

protected TaskNodeExecutor createTaskNodeExecutor()

getNodeExecutor

protected <T extends FlowNodeDefinition> FlowNodeExecutor<T> getNodeExecutor(T nodeDefinition)

startFlow

public Identifier startFlow(TriggerContext trigger)

Specified by:

startFlow in interface FlowExecutor

getStartNodeDefinition

protected FlowNodeDefinition<?> getStartNodeDefinition(Identifier definitionId,
                                                       Identifier nodeId)

trigger

public void trigger(TriggerContext trigger)

Specified by:

trigger in interface FlowExecutor

triggerNext

protected void triggerNext(TriggerContext trigger,
                           FlowNodeDefinition<?> node,
                           FlowNodeExecutionResult flowNodeExecutionResult)

createTriggerContextForNextNode

protected Trigger createTriggerContextForNextNode(TriggerContext event,
                                                  FlowNodeDefinition nextNode)

addToken

protected void addToken(TriggerContext trigger,
                        FlowNodeDefinition<?> node,
                        FlowNodeDefinition nextNode)

setTokenStore

public void setTokenStore(TokenStore tokenStore)

setTokenOperations

public void setTokenOperations(TokenOperations tokenOperations)

setDefinitionStore

public void setDefinitionStore(DefinitionStore definitionStore)

setPropertyStore

public void setPropertyStore(PropertyStore propertyStore)

setListenerManager

public void setListenerManager(ListenerManager listenerManager)

setRegistry

public void setRegistry(Registry registry)

setPredicateEvaluator

public void setPredicateEvaluator(PredicateEvaluator predicateEvaluator)

setAsyncTriggerStore

public void setAsyncTriggerStore(AsyncTriggerStore asyncTriggerStore)

setAsyncTriggerScheduler

public void setAsyncTriggerScheduler(AsyncTriggerScheduler asyncTriggerScheduler)

setCallDefinitionExecutor

public void setCallDefinitionExecutor(CallDefinitionExecutor callDefinitionExecutor)