org.axonframework.mongo.eventhandling.saga.repository

Class MongoSagaStore

java.lang.Object

org.axonframework.mongo.eventhandling.saga.repository.MongoSagaStore

All Implemented Interfaces:

org.axonframework.eventhandling.saga.repository.SagaStore<Object>

public class MongoSagaStore
extends Object
implements org.axonframework.eventhandling.saga.repository.SagaStore<Object>

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

Nested Class Summary

Nested classes/interfaces inherited from interface org.axonframework.eventhandling.saga.repository.SagaStore

org.axonframework.eventhandling.saga.repository.SagaStore.Entry<T>

Constructor Summary

Constructors

Constructor and Description
MongoSagaStore(MongoTemplate mongoTemplate) Initializes the Repository, using given mongoTemplate to access the collections containing the stored Saga instances.
MongoSagaStore(MongoTemplate mongoTemplate, org.axonframework.serialization.Serializer serializer) Initializes the Repository, using given mongoTemplate to access the collections containing the stored Saga instances, serializing Saga instances using the given serializer.

Method Summary

Modifier and Type	Method and Description
void	deleteSaga(Class<?> sagaType, String sagaIdentifier, Set<org.axonframework.eventhandling.saga.AssociationValue> associationValues)
Set<String>	findSagas(Class<?> sagaType, org.axonframework.eventhandling.saga.AssociationValue associationValue)
void	insertSaga(Class<?> sagaType, String sagaIdentifier, Object saga, org.axonframework.eventsourcing.eventstore.TrackingToken token, Set<org.axonframework.eventhandling.saga.AssociationValue> associationValues)
<S> org.axonframework.eventhandling.saga.repository.SagaStore.Entry<S>	loadSaga(Class<S> sagaType, String sagaIdentifier)
void	updateSaga(Class<?> sagaType, String sagaIdentifier, Object saga, org.axonframework.eventsourcing.eventstore.TrackingToken token, org.axonframework.eventhandling.saga.AssociationValues associationValues)

Methods inherited from class java.lang.Object

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

Constructor Detail

MongoSagaStore

public MongoSagaStore(MongoTemplate mongoTemplate)

Initializes the Repository, using given mongoTemplate to access the collections containing the stored Saga instances. Serialization is done using an XStream based serializer.

Parameters:

mongoTemplate - the template providing access to the collections

MongoSagaStore

public MongoSagaStore(MongoTemplate mongoTemplate,
                      org.axonframework.serialization.Serializer serializer)

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

Parameters:

mongoTemplate - the template providing access to the collections

serializer - the serializer to serialize Saga instances with

Method Detail

loadSaga

public <S> org.axonframework.eventhandling.saga.repository.SagaStore.Entry<S> loadSaga(Class<S> sagaType,
                                                                                       String sagaIdentifier)

Specified by:

loadSaga in interface org.axonframework.eventhandling.saga.repository.SagaStore<Object>

findSagas

public Set<String> findSagas(Class<?> sagaType,
                             org.axonframework.eventhandling.saga.AssociationValue associationValue)

Specified by:

findSagas in interface org.axonframework.eventhandling.saga.repository.SagaStore<Object>

deleteSaga

public void deleteSaga(Class<?> sagaType,
                       String sagaIdentifier,
                       Set<org.axonframework.eventhandling.saga.AssociationValue> associationValues)

Specified by:

deleteSaga in interface org.axonframework.eventhandling.saga.repository.SagaStore<Object>

updateSaga

public void updateSaga(Class<?> sagaType,
                       String sagaIdentifier,
                       Object saga,
                       org.axonframework.eventsourcing.eventstore.TrackingToken token,
                       org.axonframework.eventhandling.saga.AssociationValues associationValues)

Specified by:

updateSaga in interface org.axonframework.eventhandling.saga.repository.SagaStore<Object>

insertSaga

public void insertSaga(Class<?> sagaType,
                       String sagaIdentifier,
                       Object saga,
                       org.axonframework.eventsourcing.eventstore.TrackingToken token,
                       Set<org.axonframework.eventhandling.saga.AssociationValue> associationValues)

Specified by:

insertSaga in interface org.axonframework.eventhandling.saga.repository.SagaStore<Object>