Modifier and Type | Method and Description |
---|---|
protected AssociationValue |
SimpleSagaManager.extractAssociationValue(Class<? extends Saga> type,
EventMessage event) |
protected abstract AssociationValue |
AbstractSagaManager.extractAssociationValue(Class<? extends Saga> sagaType,
EventMessage event)
Extracts the AssociationValue from the given
event as relevant for a Saga of given
sagaType . |
AssociationValue |
AssociationValueResolver.extractAssociationValue(EventMessage event)
Extracts an Association Value from the given
event . |
Modifier and Type | Method and Description |
---|---|
Set<AssociationValue> |
AssociationValues.addedAssociations()
Returns the Set of association values that have been added since the last
AssociationValues.commit() . |
Set<AssociationValue> |
AssociationValues.asSet()
Returns this instance as a Set of Association Values.
|
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 |
AssociationValues.add(AssociationValue associationValue)
Adds the given
associationValue , if it has not been previously added. |
boolean |
AssociationValues.contains(AssociationValue associationValue)
Indicates whether this instance contains the given
associationValue . |
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 . |
boolean |
AssociationValues.remove(AssociationValue associationValue)
Removes the given
associationValue , if it is contained by this instance. |
Modifier and Type | Method and Description |
---|---|
protected AssociationValue |
AnnotatedSagaManager.extractAssociationValue(Class<? extends Saga> sagaType,
EventMessage event) |
AssociationValue |
AsyncSagaProcessingEvent.getAssociationValue()
Returns the association value based on the handler.
|
AssociationValue |
SagaMethodMessageHandler.getAssociationValue(EventMessage eventMessage)
The AssociationValue to find the saga instance with, or
null if no AssociationValue can be found on
the given eventMessage . |
Modifier and Type | Method and Description |
---|---|
Set<AssociationValue> |
AssociationValuesImpl.addedAssociations() |
Set<AssociationValue> |
AssociationValuesImpl.asSet() |
Iterator<AssociationValue> |
AssociationValuesImpl.iterator() |
Set<AssociationValue> |
AssociationValuesImpl.removedAssociations() |
Modifier and Type | Method and Description |
---|---|
boolean |
AssociationValuesImpl.add(AssociationValue associationValue) |
protected void |
AbstractAnnotatedSaga.associateWith(AssociationValue property)
Registers a AssociationValue with the given saga.
|
boolean |
AssociationValuesImpl.contains(AssociationValue associationValue) |
boolean |
AssociationValuesImpl.remove(AssociationValue associationValue) |
protected void |
AbstractAnnotatedSaga.removeAssociationWith(AssociationValue property)
Removes the given association from this Saga.
|
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> |
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 . |
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 . |
protected abstract void |
AbstractSagaRepository.removeAssociationValue(AssociationValue associationValue,
String sagaType,
String sagaIdentifier)
Removes the association value that has been associated with Saga, identified with the given
sagaIdentifier . |
protected abstract void |
AbstractSagaRepository.storeAssociationValue(AssociationValue associationValue,
String sagaType,
String sagaIdentifier)
Store the given
associationValue , which has been associated with given sagaIdentifier . |
Modifier and Type | Method and Description |
---|---|
Set<String> |
InMemorySagaRepository.find(Class<? extends Saga> type,
AssociationValue associationValue) |
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<String> |
JpaSagaRepository.findAssociatedSagaIdentifiers(Class<? extends Saga> type,
AssociationValue associationValue) |
protected void |
JpaSagaRepository.removeAssociationValue(AssociationValue associationValue,
String sagaType,
String sagaIdentifier) |
protected void |
JpaSagaRepository.storeAssociationValue(AssociationValue associationValue,
String sagaType,
String sagaIdentifier) |
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 |
---|---|
protected Set<String> |
MongoSagaRepository.findAssociatedSagaIdentifiers(Class<? extends Saga> type,
AssociationValue associationValue) |
protected void |
MongoSagaRepository.removeAssociationValue(AssociationValue associationValue,
String sagaType,
String sagaIdentifier) |
protected void |
MongoSagaRepository.storeAssociationValue(AssociationValue associationValue,
String sagaType,
String sagaIdentifier) |
Copyright © 2010-2013. All Rights Reserved.