org.axonframework.modelling.saga

Class SagaLifecycle

java.lang.Object

org.axonframework.messaging.Scope

org.axonframework.modelling.saga.SagaLifecycle

Direct Known Subclasses:

AnnotatedSaga

public abstract class SagaLifecycle
extends Scope

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.
ScopeDescriptor	describeScope() Provide a description of this Scope.
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 static SagaLifecycle	getInstance() Get the current SagaLifecycle instance for the current thread.
protected abstract String	getSagaIdentifier() Retrieve a String denoting the identifier of this Saga.
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.
protected abstract String	type() Retrieve a String denoting the type of this Saga.

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

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

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

type

protected abstract String type()

Retrieve a String denoting the type of this Saga.

Returns:

a String denoting the type of this Saga

getSagaIdentifier

protected abstract String getSagaIdentifier()

Retrieve a String denoting the identifier of this Saga.

Returns:

a String denoting the identifier of this Saga

describeScope

public ScopeDescriptor describeScope()

Description copied from class: Scope

Provide a description of this Scope.

Specified by:

describeScope in class Scope

Returns:

a ScopeDescriptor describing this Scope