Package | Description |
---|---|
org.axonframework.quickstart.saga | |
org.axonframework.saga | |
org.axonframework.saga.annotation | |
org.axonframework.saga.repository | |
org.axonframework.saga.repository.inmemory | |
org.axonframework.saga.repository.jdbc | |
org.axonframework.saga.repository.jpa | |
org.axonframework.saga.repository.mongo | |
org.axonframework.saga.spring | |
org.axonframework.test.utils |
A collection of classes which may prove useful when testing Axon-based classes.
|
Modifier and Type | Class and Description |
---|---|
class |
ToDoSaga |
Modifier and Type | Method and Description |
---|---|
<T extends Saga> |
SagaFactory.createSaga(Class<T> sagaType)
Create a new instance of a Saga of given type.
|
<T extends Saga> |
GenericSagaFactory.createSaga(Class<T> sagaType) |
Modifier and Type | Method and Description |
---|---|
Saga |
SagaRepository.load(String sagaIdentifier)
Loads a known Saga instance by its unique identifier.
|
Modifier and Type | Method and Description |
---|---|
Set<Class<? extends Saga>> |
AbstractSagaManager.getManagedSagaTypes()
Returns the set of Saga types managed by this instance.
|
Modifier and Type | Method and Description |
---|---|
void |
SagaRepository.add(Saga saga)
Registers a newly created Saga with the Repository.
|
void |
SagaRepository.commit(Saga saga)
Commits the changes made to the Saga instance.
|
protected void |
AbstractSagaManager.commit(Saga saga)
Commits the given
saga to the registered repository. |
void |
SimpleResourceInjector.injectResources(Saga saga) |
void |
ResourceInjector.injectResources(Saga saga)
Inject required resources into the given
saga . |
protected void |
AbstractSagaManager.preProcessSaga(Saga saga)
Perform pre-processing of sagas that have been newly created or have been loaded from the repository.
|
Modifier and Type | Method and Description |
---|---|
protected Set<AssociationValue> |
SimpleSagaManager.extractAssociationValues(Class<? extends Saga> type,
EventMessage event) |
protected abstract Set<AssociationValue> |
AbstractSagaManager.extractAssociationValues(Class<? extends Saga> sagaType,
EventMessage event)
Extracts the AssociationValues from the given
event as relevant for a Saga of given
sagaType . |
Set<String> |
SagaRepository.find(Class<? extends Saga> type,
AssociationValue associationValue)
Find saga instances of the given
type that have been associated with the given
associationValue . |
protected SagaInitializationPolicy |
SimpleSagaManager.getSagaCreationPolicy(Class<? extends Saga> type,
EventMessage event) |
protected abstract SagaInitializationPolicy |
AbstractSagaManager.getSagaCreationPolicy(Class<? extends Saga> sagaType,
EventMessage event)
Returns the Saga Initialization Policy for a Saga of the given
sagaType and event . |
boolean |
SagaFactory.supports(Class<? extends Saga> sagaType)
Indicates whether or not this factory can create instances of the given
sagaType . |
boolean |
GenericSagaFactory.supports(Class<? extends Saga> sagaType)
Indicates whether or not this factory can create instances of the given
sagaType . |
Constructor and Description |
---|
SimpleSagaManager(Class<? extends Saga> sagaType,
SagaRepository sagaRepository,
AssociationValueResolver associationValueResolver)
Initialize a SimpleSagaManager backed by the given resources, using a GenericSagaFactory.
|
SimpleSagaManager(Class<? extends Saga> sagaType,
SagaRepository sagaRepository,
AssociationValueResolver associationValueResolver,
EventBus eventBus)
|
SimpleSagaManager(Class<? extends Saga> sagaType,
SagaRepository sagaRepository,
AssociationValueResolver associationValueResolver,
SagaFactory sagaFactory)
Initialize a SimpleSagaManager backed by the given resources.
|
SimpleSagaManager(Class<? extends Saga> sagaType,
SagaRepository sagaRepository,
AssociationValueResolver associationValueResolver,
SagaFactory sagaFactory,
EventBus eventBus)
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractAnnotatedSaga
Implementation of the
interface that delegates incoming events to @SagaEventHandler annotated methods. |
Modifier and Type | Method and Description |
---|---|
Class<? extends Saga> |
AsyncSagaProcessingEvent.getSagaType()
Returns the type of Saga being processed.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AnnotatedSagaManager.preProcessSaga(Saga saga) |
Modifier and Type | Method and Description |
---|---|
protected Set<AssociationValue> |
AnnotatedSagaManager.extractAssociationValues(Class<? extends Saga> sagaType,
EventMessage event) |
protected SagaInitializationPolicy |
AnnotatedSagaManager.getSagaCreationPolicy(Class<? extends Saga> sagaType,
EventMessage event) |
Modifier and Type | Method and Description |
---|---|
Saga |
CachingSagaRepository.load(String sagaIdentifier) |
Modifier and Type | Method and Description |
---|---|
void |
CachingSagaRepository.add(Saga saga) |
void |
AbstractSagaRepository.add(Saga saga) |
void |
CachingSagaRepository.commit(Saga saga) |
void |
AbstractSagaRepository.commit(Saga saga) |
protected abstract void |
AbstractSagaRepository.deleteSaga(Saga saga)
Remove the given saga as well as all known association values pointing to it from the repository.
|
protected abstract void |
AbstractSagaRepository.storeSaga(Saga saga)
Stores a newly created Saga instance.
|
protected abstract void |
AbstractSagaRepository.updateSaga(Saga saga)
Update a stored Saga, by replacing it with the given
saga instance. |
Modifier and Type | Method and Description |
---|---|
Set<String> |
CachingSagaRepository.find(Class<? extends Saga> type,
AssociationValue associationValue) |
Set<String> |
AbstractSagaRepository.find(Class<? extends Saga> type,
AssociationValue associationValue) |
protected abstract Set<String> |
AbstractSagaRepository.findAssociatedSagaIdentifiers(Class<? extends Saga> type,
AssociationValue associationValue)
Finds the identifiers of the sagas of given
type associated with the given
associationValue . |
protected abstract String |
AbstractSagaRepository.typeOf(Class<? extends Saga> sagaClass)
Returns the type identifier to use for the given
sagaClass . |
Modifier and Type | Method and Description |
---|---|
Saga |
InMemorySagaRepository.load(String sagaIdentifier) |
Modifier and Type | Method and Description |
---|---|
void |
InMemorySagaRepository.add(Saga saga) |
void |
InMemorySagaRepository.commit(Saga saga) |
Modifier and Type | Method and Description |
---|---|
Set<String> |
InMemorySagaRepository.find(Class<? extends Saga> type,
AssociationValue associationValue) |
Modifier and Type | Method and Description |
---|---|
Saga |
JdbcSagaRepository.load(String sagaId) |
Modifier and Type | Method and Description |
---|---|
protected void |
JdbcSagaRepository.deleteSaga(Saga saga) |
protected void |
JdbcSagaRepository.storeSaga(Saga saga) |
protected void |
JdbcSagaRepository.updateSaga(Saga saga) |
Modifier and Type | Method and Description |
---|---|
protected Set<String> |
JdbcSagaRepository.findAssociatedSagaIdentifiers(Class<? extends Saga> type,
AssociationValue associationValue) |
protected String |
JdbcSagaRepository.typeOf(Class<? extends Saga> sagaClass) |
Modifier and Type | Method and Description |
---|---|
Saga |
SagaEntry.getSaga(Serializer serializer)
Returns the Saga instance stored in this entry.
|
Saga |
JpaSagaRepository.load(String sagaId) |
Modifier and Type | Method and Description |
---|---|
protected void |
JpaSagaRepository.deleteSaga(Saga saga) |
protected void |
JpaSagaRepository.storeSaga(Saga saga) |
protected void |
JpaSagaRepository.updateSaga(Saga saga) |
Modifier and Type | Method and Description |
---|---|
protected Set<String> |
JpaSagaRepository.findAssociatedSagaIdentifiers(Class<? extends Saga> type,
AssociationValue associationValue) |
protected String |
JpaSagaRepository.typeOf(Class<? extends Saga> sagaClass) |
Constructor and Description |
---|
SagaEntry(Saga saga,
Serializer serializer)
Constructs a new SagaEntry for the given
saga . |
Modifier and Type | Method and Description |
---|---|
Saga |
SagaEntry.getSaga(Serializer serializer)
Returns the Saga instance stored in this entry.
|
Saga |
MongoSagaRepository.load(String sagaIdentifier) |
Modifier and Type | Method and Description |
---|---|
protected void |
MongoSagaRepository.deleteSaga(Saga saga) |
protected void |
MongoSagaRepository.storeSaga(Saga saga) |
protected void |
MongoSagaRepository.updateSaga(Saga saga) |
Modifier and Type | Method and Description |
---|---|
protected Set<String> |
MongoSagaRepository.findAssociatedSagaIdentifiers(Class<? extends Saga> type,
AssociationValue associationValue) |
protected String |
MongoSagaRepository.typeOf(Class<? extends Saga> sagaClass) |
Constructor and Description |
---|
SagaEntry(Saga saga,
Serializer serializer)
Constructs a new SagaEntry for the given
saga . |
Modifier and Type | Method and Description |
---|---|
void |
SpringResourceInjector.injectResources(Saga saga) |
Modifier and Type | Method and Description |
---|---|
void |
AutowiredResourceInjector.injectResources(Saga saga) |
Copyright © 2010-2014. All Rights Reserved.