org.axonframework.saga.repository.mongo

Class MongoSagaRepository

java.lang.Object

org.axonframework.saga.repository.AbstractSagaRepository

org.axonframework.saga.repository.mongo.MongoSagaRepository

All Implemented Interfaces:

org.axonframework.saga.SagaRepository

public class MongoSagaRepository
extends org.axonframework.saga.repository.AbstractSagaRepository

Implementations of the SagaRepository that stores Sagas and their associations in a Mongo Database. Each Saga and its associations is stored as a single document.

Since:

2.0

Author:

Jettro Coenradie, Allard Buijze

Constructor Summary

Constructors

Constructor and Description
MongoSagaRepository(MongoTemplate mongoTemplate) Initializes the Repository, using given mongoTemplate to access the collections containing the stored Saga instances.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	deleteSaga(org.axonframework.saga.Saga saga)
protected Set<String>	findAssociatedSagaIdentifiers(Class<? extends org.axonframework.saga.Saga> type, org.axonframework.saga.AssociationValue associationValue)
org.axonframework.saga.Saga	load(String sagaIdentifier)
protected void	removeAssociationValue(org.axonframework.saga.AssociationValue associationValue, String sagaType, String sagaIdentifier)
void	setResourceInjector(org.axonframework.saga.ResourceInjector resourceInjector) Sets the ResourceInjector to use to inject Saga instances with any (temporary) resources they might need.
void	setSerializer(org.axonframework.serializer.Serializer serializer) Provide the serializer to use if the default JavaSagaSerializer is not the best solution.
protected void	storeAssociationValue(org.axonframework.saga.AssociationValue associationValue, String sagaType, String sagaIdentifier)
protected void	storeSaga(org.axonframework.saga.Saga saga)
protected String	typeOf(Class<? extends org.axonframework.saga.Saga> sagaClass)
protected void	updateSaga(org.axonframework.saga.Saga saga)

Methods inherited from class org.axonframework.saga.repository.AbstractSagaRepository

add, commit, find

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MongoSagaRepository

public MongoSagaRepository(MongoTemplate mongoTemplate)

Initializes the Repository, using given mongoTemplate to access the collections containing the stored Saga instances.

Parameters:

mongoTemplate - the template providing access to the collections

Method Detail

load

public org.axonframework.saga.Saga load(String sagaIdentifier)

findAssociatedSagaIdentifiers

protected Set<String> findAssociatedSagaIdentifiers(Class<? extends org.axonframework.saga.Saga> type,
                                        org.axonframework.saga.AssociationValue associationValue)

Specified by:

findAssociatedSagaIdentifiers in class org.axonframework.saga.repository.AbstractSagaRepository

typeOf

protected String typeOf(Class<? extends org.axonframework.saga.Saga> sagaClass)

Specified by:

typeOf in class org.axonframework.saga.repository.AbstractSagaRepository

deleteSaga

protected void deleteSaga(org.axonframework.saga.Saga saga)

Specified by:

deleteSaga in class org.axonframework.saga.repository.AbstractSagaRepository

updateSaga

protected void updateSaga(org.axonframework.saga.Saga saga)

Specified by:

updateSaga in class org.axonframework.saga.repository.AbstractSagaRepository

storeSaga

protected void storeSaga(org.axonframework.saga.Saga saga)

Specified by:

storeSaga in class org.axonframework.saga.repository.AbstractSagaRepository

storeAssociationValue

protected void storeAssociationValue(org.axonframework.saga.AssociationValue associationValue,
                         String sagaType,
                         String sagaIdentifier)

Specified by:

storeAssociationValue in class org.axonframework.saga.repository.AbstractSagaRepository

removeAssociationValue

protected void removeAssociationValue(org.axonframework.saga.AssociationValue associationValue,
                          String sagaType,
                          String sagaIdentifier)

Specified by:

removeAssociationValue in class org.axonframework.saga.repository.AbstractSagaRepository

setSerializer

public void setSerializer(org.axonframework.serializer.Serializer serializer)

Provide the serializer to use if the default JavaSagaSerializer is not the best solution.

Parameters:

serializer - SagaSerializer to use for sag serialization.

setResourceInjector

public void setResourceInjector(org.axonframework.saga.ResourceInjector resourceInjector)

Sets the ResourceInjector to use to inject Saga instances with any (temporary) resources they might need. These are typically the resources that could not be persisted with the Saga.

Parameters:

resourceInjector - The resource injector