org.axonframework.eventhandling.saga

Class AnnotatedSaga<T>

java.lang.Object

org.axonframework.messaging.Scope

org.axonframework.eventhandling.saga.SagaLifecycle

org.axonframework.eventhandling.saga.AnnotatedSaga<T>

All Implemented Interfaces:

EventListener, Saga<T>

public class AnnotatedSaga<T>
extends SagaLifecycle
implements Saga<T>

Implementation of the interface that allows for a POJO instance with annotated message handlers to act as a Saga. The POJO instance can access static methods on SagaLifecycle as long as it is access via the execute(Consumer) or invoke(Function) methods.

Since:

3.0

Author:

Allard Buijze

Constructor Summary

Constructors

Constructor and Description
AnnotatedSaga(String sagaId, Set<AssociationValue> associationValues, T annotatedSaga, TrackingToken trackingToken, SagaModel<T> metaModel) Creates an AnnotatedSaga instance to wrap the given annotatedSaga, identifier with the given sagaId and associated with the given associationValues.

Method Summary

Modifier and Type	Method and Description
boolean	canHandle(EventMessage<?> event) Indicates whether this listener can handle the given event message
protected void	doAssociateWith(AssociationValue property) Registers a AssociationValue with the given saga.
protected void	doEnd() Marks the saga as ended.
protected void	doRemoveAssociation(AssociationValue property) Removes the given association from this Saga.
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() Retrieve a String denoting the identifier of this Saga.
void	handle(EventMessage<?> event) Process the given event.
<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.
T	root() Returns the (annotated) Saga instance.
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.
protected String	type() Retrieve a String denoting the type of this Saga.

Methods inherited from class org.axonframework.eventhandling.saga.SagaLifecycle

associateWith, associateWith, associateWith, describeScope, end, execute, getInstance, removeAssociationWith, removeAssociationWith

Methods inherited from class org.axonframework.messaging.Scope

describeCurrentScope, endScope, executeWithResult, getCurrentScope, startScope

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.axonframework.eventhandling.saga.Saga

prepareReset, supportsReset

Constructor Detail

AnnotatedSaga

public AnnotatedSaga(String sagaId,
                     Set<AssociationValue> associationValues,
                     T annotatedSaga,
                     TrackingToken trackingToken,
                     SagaModel<T> metaModel)

Creates an AnnotatedSaga instance to wrap the given annotatedSaga, identifier with the given sagaId and associated with the given associationValues. The metaModel provides the description of the structure of the Saga.

Parameters:

sagaId - The identifier of this Saga instance

associationValues - The current associations of this Saga

annotatedSaga - The object instance representing the Saga

trackingToken - The token identifying the position in a stream the saga has last processed

metaModel - The model describing Saga structure

Method Detail

getSagaIdentifier

public String getSagaIdentifier()

Description copied from class: SagaLifecycle

Retrieve a String denoting the identifier of this Saga.

Specified by:

getSagaIdentifier in interface Saga<T>

Specified by:

getSagaIdentifier in class SagaLifecycle

Returns:

a String denoting the identifier of this Saga

getAssociationValues

public AssociationValues getAssociationValues()

Description copied from interface: Saga

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

Specified by:

getAssociationValues in interface Saga<T>

Returns:

a view on the Association Values for this saga instance

invoke

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

Description copied from interface: Saga

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

Specified by:

invoke in interface Saga<T>

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

public void execute(Consumer<T> invocation)

Description copied from interface: Saga

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

Specified by:

execute in interface Saga<T>

Parameters:

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

canHandle

public final boolean canHandle(EventMessage<?> event)

Description copied from interface: EventListener

Indicates whether this listener can handle the given event message

Specified by:

canHandle in interface EventListener

Parameters:

event - The event message to verify

Returns:

true if this listener can handle the event, otherwise false

handle

public final void handle(EventMessage<?> event)

Description copied from interface: EventListener

Process the given event. The implementation may decide to process or skip the given event. It is highly unrecommended to throw any exception during the event handling process.

Specified by:

handle in interface EventListener

Parameters:

event - the event to handle

isActive

public boolean isActive()

Description copied from interface: Saga

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

Specified by:

isActive in interface Saga<T>

Returns:

true if this saga is active, false otherwise.

trackingToken

public TrackingToken trackingToken()

Description copied from interface: Saga

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.

Specified by:

trackingToken in interface Saga<T>

Returns:

the TrackingToken of the last processed EventMessage, if present.

root

public T root()

Returns the (annotated) Saga instance. This method should not be used to modify the Saga's state, as it doesn't allow the instance to access the static methods on SagaLifecycle.

Returns:

the Saga instance

doEnd

protected void doEnd()

Marks the saga as ended. Ended saga's may be cleaned up by the repository when they are committed.

Specified by:

doEnd in class SagaLifecycle

doAssociateWith

protected void doAssociateWith(AssociationValue property)

Registers a AssociationValue with the given saga. When the saga is committed, it can be found using the registered property.

Specified by:

doAssociateWith in class SagaLifecycle

Parameters:

property - The value to associate this saga with.

type

protected String type()

Description copied from class: SagaLifecycle

Retrieve a String denoting the type of this Saga.

Specified by:

type in class SagaLifecycle

Returns:

a String denoting the type of this Saga

doRemoveAssociation

protected void doRemoveAssociation(AssociationValue property)

Removes the given association from this Saga. When the saga is committed, it can no longer be found using the given association. If the given property wasn't registered with the saga, nothing happens.

Specified by:

doRemoveAssociation in class SagaLifecycle

Parameters:

property - the association value to remove from the saga.