org.axonframework.mongo

Class DefaultMongoTemplate

java.lang.Object

org.axonframework.mongo.AbstractMongoTemplate

org.axonframework.mongo.DefaultMongoTemplate

All Implemented Interfaces:

MongoTemplate

public class DefaultMongoTemplate
extends AbstractMongoTemplate
implements MongoTemplate

MongoTemplate instance giving direct access to the TrackingToken collection via a given MongoClient instance.

Constructor Summary

Constructors

Constructor and Description
DefaultMongoTemplate(com.mongodb.MongoClient mongo) Initialize a template for the given mongoDb instance, using default database name ("axonframework") and collection names ("domainevents", "snapshotevents", "sagas" and "trackingtokens").
DefaultMongoTemplate(com.mongodb.MongoClient mongo, String databaseName) Initialize a template for the given mongoDb instance, using given databaseName and default collection names ("domainevents", "snapshotevents", "sagas" and "trackingtokens").

Method Summary

Modifier and Type	Method and Description
com.mongodb.client.MongoCollection<org.bson.Document>	eventCollection() Returns a reference to the collection containing the events.
com.mongodb.client.MongoCollection<org.bson.Document>	sagaCollection() Returns a reference to the collection containing the saga instances.
com.mongodb.client.MongoCollection<org.bson.Document>	snapshotCollection() Returns a reference to the collection containing the snapshot events.
com.mongodb.client.MongoCollection<org.bson.Document>	trackingTokensCollection() Returns a reference to the collection containing the Tracking Tokens.
DefaultMongoTemplate	withDomainEventsCollection(String domainEventsCollectionName)
DefaultMongoTemplate	withSagasCollection(String sagasCollectionName)
DefaultMongoTemplate	withSnapshotCollection(String snapshotEventsCollectionName)
DefaultMongoTemplate	withTrackingTokenCollection(String trackingTokensCollectionName)

Methods inherited from class org.axonframework.mongo.AbstractMongoTemplate

database

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultMongoTemplate

public DefaultMongoTemplate(com.mongodb.MongoClient mongo)

Initialize a template for the given mongoDb instance, using default database name ("axonframework") and collection names ("domainevents", "snapshotevents", "sagas" and "trackingtokens").

Parameters:

mongo - The Mongo instance providing access to the database

DefaultMongoTemplate

public DefaultMongoTemplate(com.mongodb.MongoClient mongo,
                            String databaseName)

Initialize a template for the given mongoDb instance, using given databaseName and default collection names ("domainevents", "snapshotevents", "sagas" and "trackingtokens").

Parameters:

mongo - The Mongo instance providing access to the database

databaseName - The name of the database to connect to

Method Detail

withSnapshotCollection

public DefaultMongoTemplate withSnapshotCollection(String snapshotEventsCollectionName)

withDomainEventsCollection

public DefaultMongoTemplate withDomainEventsCollection(String domainEventsCollectionName)

withSagasCollection

public DefaultMongoTemplate withSagasCollection(String sagasCollectionName)

withTrackingTokenCollection

public DefaultMongoTemplate withTrackingTokenCollection(String trackingTokensCollectionName)

trackingTokensCollection

public com.mongodb.client.MongoCollection<org.bson.Document> trackingTokensCollection()

Description copied from interface: MongoTemplate

Returns a reference to the collection containing the Tracking Tokens.

Specified by:

trackingTokensCollection in interface MongoTemplate

Returns:

MongoCollection containing the Tracking Tokens

eventCollection

public com.mongodb.client.MongoCollection<org.bson.Document> eventCollection()

Description copied from interface: MongoTemplate

Returns a reference to the collection containing the events.

Specified by:

eventCollection in interface MongoTemplate

Returns:

MongoCollection containing the domain events

snapshotCollection

public com.mongodb.client.MongoCollection<org.bson.Document> snapshotCollection()

Description copied from interface: MongoTemplate

Returns a reference to the collection containing the snapshot events.

Specified by:

snapshotCollection in interface MongoTemplate

Returns:

MongoCollection containing the snapshot events

sagaCollection

public com.mongodb.client.MongoCollection<org.bson.Document> sagaCollection()

Description copied from interface: MongoTemplate

Returns a reference to the collection containing the saga instances.

Specified by:

sagaCollection in interface MongoTemplate

Returns:

MongoCollection containing the sagas