Package org.springframework.statemachine.recipes.tasks

Class TasksHandler

java.lang.Object

org.springframework.statemachine.recipes.tasks.TasksHandler

public class TasksHandler
extends Object

TasksHandler is a recipe for executing arbitrary Runnable tasks using a state machine logic. This recipe supports execution of multiple top-level tasks with a sub-states construct of DAGs.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TasksHandler.Builder	Builder pattern implementation building a TasksHandler.
static interface	TasksHandler.TasksListener	TasksListener is a generic interface listening tasks execution events.
static class	TasksHandler.TasksListenerAdapter	Adapter class for TasksHandler.TasksListener.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	EVENT_CONTINUE
static final String	EVENT_FALLBACK
static final String	EVENT_FIX
static final String	EVENT_RUN
static final String	STATE_AUTOMATIC
static final String	STATE_CHOICE
static final String	STATE_ERROR
static final String	STATE_FORK
static final String	STATE_JOIN
static final String	STATE_MANUAL
static final String	STATE_READY
static final String	STATE_TASKS
static final String	STATE_TASKS_INITIAL_POSTFIX
static final String	STATE_TASKS_PREFIX

Method Summary

Modifier and Type	Method	Description
void	addTasksListener(TasksHandler.TasksListener listener)	Adds the tasks listener.
static TasksHandler.Builder	builder()	Gets a new instance of a TasksHandler.Builder which is used to build an instance of a TasksHandler.
void	continueFromError()	Request to continue from an error.
void	fixCurrentProblems()	Request to fix current problems.
StateMachine<String,String>	getStateMachine()	Gets the internal state machine used by executing tasks.
void	markAllTasksFixed()	Mark all extended state variables related to tasks fixed.
void	removeTasksListener(TasksHandler.TasksListener listener)	Removes the tasks listener.
void	resetFromPersistStore()	Resets state machine states from a backing persistent repository.
void	runTasks()	Request to execute current tasks logic.

Methods inherited from class java.lang.Object

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

Field Details

STATE_READY

public static final String STATE_READY

See Also:

• Constant Field Values

STATE_FORK

public static final String STATE_FORK

See Also:

• Constant Field Values

STATE_TASKS

public static final String STATE_TASKS

See Also:

• Constant Field Values

STATE_JOIN

public static final String STATE_JOIN

See Also:

• Constant Field Values

STATE_CHOICE

public static final String STATE_CHOICE

See Also:

• Constant Field Values

STATE_ERROR

public static final String STATE_ERROR

See Also:

• Constant Field Values

STATE_AUTOMATIC

public static final String STATE_AUTOMATIC

See Also:

• Constant Field Values

STATE_MANUAL

public static final String STATE_MANUAL

See Also:

• Constant Field Values

STATE_TASKS_PREFIX

public static final String STATE_TASKS_PREFIX

See Also:

• Constant Field Values

STATE_TASKS_INITIAL_POSTFIX

public static final String STATE_TASKS_INITIAL_POSTFIX

See Also:

• Constant Field Values

EVENT_RUN

public static final String EVENT_RUN

See Also:

• Constant Field Values

EVENT_FALLBACK

public static final String EVENT_FALLBACK

See Also:

• Constant Field Values

EVENT_CONTINUE

public static final String EVENT_CONTINUE

See Also:

• Constant Field Values

EVENT_FIX

public static final String EVENT_FIX

See Also:

• Constant Field Values

Method Details

runTasks

public void runTasks()

Request to execute current tasks logic.

continueFromError

public void continueFromError()

Request to continue from an error.

fixCurrentProblems

public void fixCurrentProblems()

Request to fix current problems.

resetFromPersistStore

public void resetFromPersistStore()

Resets state machine states from a backing persistent repository. If StateMachinePersist is not set this method doesn't do anything. StateMachine is stopped before states are reseted from a persistent store and started afterwards.

addTasksListener

public void addTasksListener(TasksHandler.TasksListener listener)

Adds the tasks listener.

Parameters:

listener - the listener

removeTasksListener

public void removeTasksListener(TasksHandler.TasksListener listener)

Removes the tasks listener.

Parameters:

listener - the listener

getStateMachine

public StateMachine<String,String> getStateMachine()

Gets the internal state machine used by executing tasks.

Returns:

the state machine

builder

public static TasksHandler.Builder builder()

Gets a new instance of a TasksHandler.Builder which is used to build an instance of a TasksHandler.

Returns:

the tasks handler builder

markAllTasksFixed

public void markAllTasksFixed()

Mark all extended state variables related to tasks fixed.