Modifier and Type | Method and Description |
---|---|
AssociationValue |
SagaMethodMessageHandlingMember.getAssociationValue(EventMessage<?> eventMessage)
The AssociationValue to find the saga instance with, or
null if no AssociationValue can be found on
the given eventMessage . |
AssociationValue |
SagaInitializationPolicy.getInitialAssociationValue()
Returns the initial association value for a newly created saga.
|
Modifier and Type | Method and Description |
---|---|
Set<AssociationValue> |
AssociationValuesImpl.addedAssociations() |
Set<AssociationValue> |
AssociationValues.addedAssociations()
Returns the Set of association values that have been added since the last
AssociationValues.commit() . |
Set<AssociationValue> |
AssociationValuesImpl.asSet() |
Set<AssociationValue> |
AssociationValues.asSet()
Returns this instance as a Set of Association Values.
|
protected Set<AssociationValue> |
AnnotatedSagaManager.extractAssociationValues(EventMessage<?> event) |
protected abstract Set<AssociationValue> |
AbstractSagaManager.extractAssociationValues(EventMessage<?> event)
Extracts the AssociationValues from the given
event as relevant for a Saga of given
sagaType . |
Iterator<AssociationValue> |
AssociationValuesImpl.iterator() |
Set<AssociationValue> |
AssociationValuesImpl.removedAssociations() |
Set<AssociationValue> |
AssociationValues.removedAssociations()
Returns the Set of association values that have been removed since the last
AssociationValues.commit() . |
Modifier and Type | Method and Description |
---|---|
boolean |
AssociationValuesImpl.add(AssociationValue associationValue) |
boolean |
AssociationValues.add(AssociationValue associationValue)
Adds the given
associationValue , if it has not been previously added. |
static void |
SagaLifecycle.associateWith(AssociationValue associationValue)
Registers a AssociationValue with the currently active saga.
|
boolean |
AssociationValuesImpl.contains(AssociationValue associationValue) |
boolean |
AssociationValues.contains(AssociationValue associationValue)
Indicates whether this instance contains the given
associationValue . |
protected abstract void |
SagaLifecycle.doAssociateWith(AssociationValue associationValue)
SagaLifecycle instance method to register the given associationValue . |
protected void |
AnnotatedSaga.doAssociateWith(AssociationValue property)
Registers a AssociationValue with the given saga.
|
protected abstract void |
SagaLifecycle.doRemoveAssociation(AssociationValue associationValue)
SagaLifecycle instance method to remove the given associationValue . |
protected void |
AnnotatedSaga.doRemoveAssociation(AssociationValue property)
Removes the given association from this Saga.
|
Set<String> |
SagaRepository.find(AssociationValue associationValue)
Find saga instances of the given
type that have been associated with the given
associationValue . |
boolean |
AssociationValuesImpl.remove(AssociationValue associationValue) |
boolean |
AssociationValues.remove(AssociationValue associationValue)
Removes the given
associationValue , if it is contained by this instance. |
Constructor and Description |
---|
SagaInitializationPolicy(SagaCreationPolicy creationPolicy,
AssociationValue initialAssociationValue)
Creates an instance using the given
creationPolicy and initialAssociationValue . |
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 . |
AssociationValuesImpl(Set<AssociationValue> initialValues)
Initializes a new AssociationValues object with given initial associations.
|
Modifier and Type | Method and Description |
---|---|
Optional<AssociationValue> |
SagaModel.resolveAssociation(EventMessage<?> eventMessage)
|
Modifier and Type | Method and Description |
---|---|
Set<AssociationValue> |
SagaStore.Entry.associationValues()
Returns the Set of association values of the fetched Saga entry.
|
Modifier and Type | Method and Description |
---|---|
void |
AssociationValueMap.add(AssociationValue associationValue,
String sagaType,
String sagaIdentifier)
Adds an association between the given
associationValue and sagaIdentifier . |
Set<String> |
AnnotatedSagaRepository.find(AssociationValue associationValue) |
Set<String> |
SagaStore.findSagas(Class<? extends T> sagaType,
AssociationValue associationValue)
Returns identifiers of saga instances of the given
sagaType that have been associated with the given
associationValue . |
Set<String> |
CachingSagaStore.findSagas(Class<? extends T> sagaType,
AssociationValue associationValue) |
Set<String> |
AssociationValueMap.findSagas(String sagaType,
AssociationValue associationValue)
Returns the identifiers of the Sagas that have been associated with the given
associationValue . |
void |
AssociationValueMap.remove(AssociationValue associationValue,
String sagaType,
String sagaIdentifier)
Removes an association between the given
associationValue and sagaIdentifier . |
Modifier and Type | Method and Description |
---|---|
protected void |
CachingSagaStore.addCachedAssociations(Iterable<AssociationValue> associationValues,
String sagaIdentifier,
Class<?> sagaType)
Registers the associations of a saga with given
sagaIdentifier and given sagaType with the
associations cache. |
void |
SagaStore.deleteSaga(Class<? extends T> sagaType,
String sagaIdentifier,
Set<AssociationValue> associationValues)
Deletes a Saga with given
sagaType and sagaIdentifier and all its associations. |
void |
CachingSagaStore.deleteSaga(Class<? extends T> sagaType,
String sagaIdentifier,
Set<AssociationValue> associationValues) |
void |
SagaStore.insertSaga(Class<? extends T> sagaType,
String sagaIdentifier,
T saga,
TrackingToken token,
Set<AssociationValue> associationValues)
Adds a new Saga and its initial association values to the store.
|
void |
CachingSagaStore.insertSaga(Class<? extends T> sagaType,
String sagaIdentifier,
T saga,
TrackingToken token,
Set<AssociationValue> associationValues) |
Modifier and Type | Method and Description |
---|---|
Set<String> |
InMemorySagaStore.findSagas(Class<?> sagaType,
AssociationValue associationValue) |
Modifier and Type | Method and Description |
---|---|
void |
InMemorySagaStore.deleteSaga(Class<?> sagaType,
String sagaIdentifier,
Set<AssociationValue> associationValues) |
void |
InMemorySagaStore.insertSaga(Class<?> sagaType,
String sagaIdentifier,
Object saga,
TrackingToken token,
Set<AssociationValue> associationValues) |
Modifier and Type | Method and Description |
---|---|
Set<AssociationValue> |
SagaSqlSchema.readAssociationValues(ResultSet resultSet)
Reads a Set of AssociationValues from the given
resultSet , which has been returned by executing the
Statement returned from SagaSqlSchema.sql_findAssociations(Connection, String, String) . |
Set<AssociationValue> |
GenericSagaSqlSchema.readAssociationValues(ResultSet resultSet) |
Modifier and Type | Method and Description |
---|---|
Set<String> |
JdbcSagaStore.findSagas(Class<?> sagaType,
AssociationValue associationValue) |
Modifier and Type | Method and Description |
---|---|
void |
JdbcSagaStore.deleteSaga(Class<?> sagaType,
String sagaIdentifier,
Set<AssociationValue> associationValues) |
void |
JdbcSagaStore.insertSaga(Class<?> sagaType,
String sagaIdentifier,
Object saga,
TrackingToken token,
Set<AssociationValue> associationValues) |
Modifier and Type | Method and Description |
---|---|
AssociationValue |
AssociationValueEntry.getAssociationValue()
Returns the association value contained in this entry.
|
Modifier and Type | Method and Description |
---|---|
protected Set<AssociationValue> |
JpaSagaStore.loadAssociationValues(javax.persistence.EntityManager entityManager,
Class<?> sagaType,
String sagaIdentifier)
|
Modifier and Type | Method and Description |
---|---|
Set<String> |
JpaSagaStore.findSagas(Class<?> sagaType,
AssociationValue associationValue) |
protected void |
JpaSagaStore.removeAssociationValue(javax.persistence.EntityManager entityManager,
Class<?> sagaType,
String sagaIdentifier,
AssociationValue associationValue)
Removes the given
associationValue of the saga with given sagaIdentifier and sagaType . |
protected void |
JpaSagaStore.storeAssociationValue(javax.persistence.EntityManager entityManager,
Class<?> sagaType,
String sagaIdentifier,
AssociationValue associationValue)
Stores the given
associationValue of the saga with given sagaIdentifier and sagaType . |
Modifier and Type | Method and Description |
---|---|
void |
JpaSagaStore.deleteSaga(Class<?> sagaType,
String sagaIdentifier,
Set<AssociationValue> associationValues) |
void |
JpaSagaStore.insertSaga(Class<?> sagaType,
String sagaIdentifier,
Object saga,
TrackingToken token,
Set<AssociationValue> associationValues) |
Constructor and Description |
---|
AssociationValueEntry(String sagaType,
String sagaIdentifier,
AssociationValue associationValue)
Initialize a new AssociationValueEntry for a saga with given
sagaIdentifier and
associationValue . |
Modifier and Type | Method and Description |
---|---|
Set<AssociationValue> |
SagaEntry.getAssociationValues()
Get a set of all the Saga's associations.
|
Modifier and Type | Method and Description |
---|---|
Set<String> |
MongoSagaStore.findSagas(Class<?> sagaType,
AssociationValue associationValue) |
Modifier and Type | Method and Description |
---|---|
void |
MongoSagaStore.deleteSaga(Class<?> sagaType,
String sagaIdentifier,
Set<AssociationValue> associationValues) |
void |
MongoSagaStore.insertSaga(Class<?> sagaType,
String sagaIdentifier,
Object saga,
TrackingToken token,
Set<AssociationValue> associationValues) |
Constructor and Description |
---|
SagaEntry(String identifier,
T saga,
Set<AssociationValue> associationValues,
Serializer serializer)
Constructs a new SagaEntry for the given
saga . |
Copyright © 2010–2018. All rights reserved.