org.axonframework.eventhandling.saga

Interface Saga<T>

All Superinterfaces:

EventListener

All Known Implementing Classes:

AnnotatedSaga

public interface Saga<T>
extends EventListener

Interface describing an implementation of a Saga. Sagas are instances that handle events and may possibly produce new commands or have other side effects. Typically, Sagas are used to manage long running business transactions.

Multiple instances of a single type of Saga may exist. In that case, each Saga will be managing a different transaction. Sagas need to be associated with concepts in order to receive specific events. These associations are managed through AssociationValues. For example, to associate a saga with an Order with ID 1234, this saga needs an association value with key "orderId" and value "1234".

Since:

0.7

Author:

Allard Buijze

Method Summary

Modifier and Type	Method and Description
void	execute(Consumer<T> invocation) Execute the given invocation against the root object of this Saga instance.
AssociationValues	getAssociationValues() Returns a view on the Association Values for this saga instance.
String	getSagaIdentifier() Returns the unique identifier of this saga.
<R> R	invoke(Function<T,R> invocation) Execute the given invocation against the root object of this Saga instance.
boolean	isActive() Indicates whether or not this saga is active.
default void	prepareReset() Performs any activities that are required to reset the state managed by handlers assigned to this invoker.
default boolean	supportsReset() Indicates whether the handlers managed by this invoker support a reset.
TrackingToken	trackingToken() Returns the TrackingToken belonging to the EventMessage last processed by this instance, or null if this instance never handled an EventMessage, or if it received an EventMessage that doesn't carry a TrackingToken.

Methods inherited from interface org.axonframework.eventhandling.EventListener

canHandle, handle

Method Detail

getSagaIdentifier

String getSagaIdentifier()

Returns the unique identifier of this saga.

Returns:

the unique identifier of this saga

getAssociationValues

AssociationValues getAssociationValues()

Returns a view on the Association Values for this saga instance. The returned instance is mutable.

Returns:

a view on the Association Values for this saga instance

invoke

<R> R invoke(Function<T,R> invocation)

Execute the given invocation against the root object of this Saga instance.

Type Parameters:

R - The type of return value expected

Parameters:

invocation - the function to invoke. The root object of the Saga is input to the function, the result is the result of the execution.

Returns:

The result of the invocation on the Saga.

execute

void execute(Consumer<T> invocation)

Execute the given invocation against the root object of this Saga instance.

Parameters:

invocation - the function to invoke. The root object of the Saga is input to the function.

isActive

boolean isActive()

Indicates whether or not this saga is active. A Saga is active when its life cycle has not been ended.

Returns:

true if this saga is active, false otherwise.

trackingToken

TrackingToken trackingToken()

Returns the TrackingToken belonging to the EventMessage last processed by this instance, or null if this instance never handled an EventMessage, or if it received an EventMessage that doesn't carry a TrackingToken.

Returns:

the TrackingToken of the last processed EventMessage, if present.

supportsReset

default boolean supportsReset()

Description copied from interface: EventListener

Indicates whether the handlers managed by this invoker support a reset.

Specified by:

supportsReset in interface EventListener

Returns:

true if a reset is supported, otherwise false

prepareReset

default void prepareReset()

Description copied from interface: EventListener

Performs any activities that are required to reset the state managed by handlers assigned to this invoker.

Specified by:

prepareReset in interface EventListener