org.axonframework.eventhandling.saga

Class SagaLifecycle

java.lang.Object

org.axonframework.eventhandling.saga.SagaLifecycle

Direct Known Subclasses:

AnnotatedSaga

public abstract class SagaLifecycle
extends Object

Abstract base class of a component that models a saga's life cycle.

Constructor Summary

Constructors

Constructor and Description
SagaLifecycle()

Method Summary

Modifier and Type	Method and Description
static void	associateWith(AssociationValue associationValue) Registers a AssociationValue with the currently active saga.
static void	associateWith(String associationKey, Number associationValue) Registers a AssociationValue with the currently active saga.
static void	associateWith(String associationKey, String associationValue) Registers a AssociationValue with the currently active saga.
protected abstract void	doAssociateWith(AssociationValue associationValue) SagaLifecycle instance method to register the given associationValue.
protected abstract void	doEnd() SagaLifecycle instance method to mark the current saga as ended.
protected abstract void	doRemoveAssociation(AssociationValue associationValue) SagaLifecycle instance method to remove the given associationValue.
static void	end() Marks the saga as ended.
protected void	execute(Runnable task) SagaLifecycle instance method to execute given task in the context of this SagaLifeCycle.
protected <V> V	executeWithResult(Callable<V> task) SagaLifecycle instance method to execute given task in the context of this SagaLifeCycle.
protected static SagaLifecycle	getInstance() Get the current SagaLifecycle instance for the current thread.
static void	removeAssociationWith(String associationKey, Number associationValue) Removes the given association from the currently active Saga.
static void	removeAssociationWith(String associationKey, String associationValue) Removes the given association from the currently active Saga.

Methods inherited from class java.lang.Object

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

Constructor Detail

SagaLifecycle

public SagaLifecycle()

Method Detail

associateWith

public static void associateWith(String associationKey,
                                 String associationValue)

Registers a AssociationValue with the currently active saga. When the saga is committed, it can be found using the registered property. If the saga already has the given association, nothing happens.

Parameters:

associationKey - The key of the association value to associate this saga with.

associationValue - The value of the association value to associate this saga with.

associateWith

public static void associateWith(String associationKey,
                                 Number associationValue)

Registers a AssociationValue with the currently active saga. When the saga is committed, it can be found using the registered property. The number value will be converted to a string. If the saga already has the given association, nothing happens.

Parameters:

associationKey - The key of the association value to associate this saga with.

associationValue - The value of the association value to associate this saga with.

associateWith

public static void associateWith(AssociationValue associationValue)

Registers a AssociationValue with the currently active saga. When the saga is committed, it can be found using the registered property. If the saga already has the given association, nothing happens.

Parameters:

associationValue - The association to associate this saga with.

removeAssociationWith

public static void removeAssociationWith(String associationKey,
                                         String associationValue)

Removes the given association from the currently active Saga. When the saga is committed, it can no longer be found using the given association value. If the given saga wasn't associated with given values, nothing happens.

Parameters:

associationKey - The key of the association value to remove from this saga.

associationValue - The value of the association value to remove from this saga.

removeAssociationWith

public static void removeAssociationWith(String associationKey,
                                         Number associationValue)

Removes the given association from the currently active Saga. When the saga is committed, it can no longer be found using the given association value. If the given saga wasn't associated with given values, nothing happens. The number value will be converted to a string.

Parameters:

associationKey - The key of the association value to remove from this saga.

associationValue - The value of the association value to remove from this saga.

end

public static void end()

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

doEnd

protected abstract void doEnd()

SagaLifecycle instance method to mark the current saga as ended.

doRemoveAssociation

protected abstract void doRemoveAssociation(AssociationValue associationValue)

SagaLifecycle instance method to remove the given associationValue. If the current saga is not associated with given value, this should do nothing.

Parameters:

associationValue - the association value to remove

doAssociateWith

protected abstract void doAssociateWith(AssociationValue associationValue)

SagaLifecycle instance method to register the given associationValue. If the current saga is already associated with given value, this should do nothing.

Parameters:

associationValue - the association value to add

getInstance

protected static SagaLifecycle getInstance()

Get the current SagaLifecycle instance for the current thread. If none exists an IllegalStateException is thrown.

Returns:

the thread's current SagaLifecycle

executeWithResult

protected <V> V executeWithResult(Callable<V> task)
                           throws Exception

SagaLifecycle instance method to execute given task in the context of this SagaLifeCycle. This updates the thread's current saga lifecycle before executing the task. If a lifecycle is already registered with the current thread that one will be temporarily replaced with this lifecycle until the task completes. This method returns the execution result of the task.

Type Parameters:

V - the type of execution result of the task

Parameters:

task - the task to execute

Returns:

the execution result

Throws:

Exception - if executing the task results in an exception

execute

protected void execute(Runnable task)

SagaLifecycle instance method to execute given task in the context of this SagaLifeCycle. This updates the thread's current saga lifecycle before executing the task. If a lifecycle is already registered with the current thread that one will be temporarily replaced with this lifecycle until the task completes.

Parameters:

task - the task to execute