| 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.