A B C D E F G H I L M O P Q R S T U W

A

AbstractMongoEventStorageStrategy - Class in org.axonframework.mongo.eventsourcing.eventstore

Abstract implementation of a Mongo StorageStrategy.

AbstractMongoEventStorageStrategy(EventEntryConfiguration, Duration) - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

Initializes a new StorageStrategy for a EventStorageEngine that uses Mongo.

AbstractMongoTemplate - Class in org.axonframework.mongo

Abstract implementation for Mongo templates.

AbstractMongoTemplate(MongoClient) - Constructor for class org.axonframework.mongo.AbstractMongoTemplate

Initializes the MongoTemplate to connect using the given mongo instance and a database with default name "axonframework".

AbstractMongoTemplate(MongoClient, String) - Constructor for class org.axonframework.mongo.AbstractMongoTemplate

Initializes the MongoTemplate to connect using the given mongo instance and the database with given databaseName.

AbstractMongoTemplate(MongoDatabase) - Constructor for class org.axonframework.mongo.AbstractMongoTemplate

Initializes the MongoTemplate to connect using the given database instance.

addAttribute(String, String) - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamWriter

addChildNode(String) - Method in class org.axonframework.mongo.serialization.BSONNode

Adds a child node to the current node.

advanceTo(Instant, String, Duration) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoTrackingToken

Returns a new MongoTrackingToken instance based on this token but which has advanced to the event with given timestamp, eventIdentifier and sequenceNumber.

aggregateIdentifierProperty() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration

Get the name of the property with the aggregate identifier of the event.

appendErrors(ErrorWriter) - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamReader

appendEvents(MongoCollection<Document>, List<? extends EventMessage<?>>, Serializer) - Method in class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

appendEvents(List<? extends EventMessage<?>>, Serializer) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoEventStorageEngine

appendEvents(MongoCollection<Document>, List<? extends EventMessage<?>>, Serializer) - Method in interface org.axonframework.mongo.eventsourcing.eventstore.StorageStrategy

Appends the given list of events to the given eventCollection.

appendSnapshot(MongoCollection<Document>, DomainEventMessage<?>, Serializer) - Method in class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

appendSnapshot(MongoCollection<Document>, DomainEventMessage<?>, Serializer) - Method in interface org.axonframework.mongo.eventsourcing.eventstore.StorageStrategy

Append the given aggregate snapshot to the snapshotCollection.

asDBObject() - Method in class org.axonframework.mongo.serialization.BSONNode

Returns the current BSON structure as DBObject.

asDocument() - Method in class org.axonframework.mongo.eventhandling.saga.repository.SagaEntry

Returns the Mongo Document representing the Saga provided in this entry.

asDocument(CommitEntryConfiguration, EventEntryConfiguration) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.CommitEntry

Returns the current CommitEntry as a mongo Document.

asDocument(EventEntryConfiguration) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntry

Returns the current entry as a mongo Document.

attributes() - Method in class org.axonframework.mongo.serialization.BSONNode

Returns a map containing the attributes of the current node.

B

BSONNode - Class in org.axonframework.mongo.serialization

Represents a node in a BSON structure.

BSONNode(String) - Constructor for class org.axonframework.mongo.serialization.BSONNode

Creates a node with given "code" name.

build() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration.Builder

builder() - Static method in class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.CommitEntryConfiguration

Returns a new builder that is initialized with default values.

builder() - Static method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration

Returns a new Builder for an EventEntryConfiguration initialized with default settings.

Builder() - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration.Builder

C

children() - Method in class org.axonframework.mongo.serialization.BSONNode

Returns an iterator providing access to the child nodes of the current node.

close() - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamReader

close() - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamWriter

CommitEntry - Class in org.axonframework.mongo.eventsourcing.eventstore.documentpercommit

Mongo event storage entry containing an array of event entries that are part of the same UnitOfWork commit.

CommitEntry(List<? extends DomainEventMessage<?>>, Serializer) - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.CommitEntry

Constructor used to create a new event entry to store in Mongo.

CommitEntry(Document, CommitEntryConfiguration, EventEntryConfiguration) - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.CommitEntry

Creates a new CommitEntry based on data provided by Mongo.

CommitEntryConfiguration - Class in org.axonframework.mongo.eventsourcing.eventstore.documentpercommit

Configuration for a mongo event store entry that contains an array of event entries that are part of the same UnitOfWork commit.

convert(DBObject) - Method in class org.axonframework.mongo.serialization.DBObjectToStringContentTypeConverter

convert(Document) - Method in class org.axonframework.mongo.serialization.DocumentToStringContentTypeConverter

convert(String) - Method in class org.axonframework.mongo.serialization.StringToDBObjectContentTypeConverter

covers(TrackingToken) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoTrackingToken

createEventDocuments(List<? extends EventMessage<?>>, Serializer) - Method in class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

Returns a stream of Mongo documents that represent the given batch of events.

createEventDocuments(List<? extends EventMessage<?>>, Serializer) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.DocumentPerCommitStorageStrategy

createEventDocuments(List<? extends EventMessage<?>>, Serializer) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.DocumentPerEventStorageStrategy

createHeadToken() - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoEventStorageEngine

createMongo() - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoFactory

Creates a mongo instance based on the provided configuration.

createMongoOptions() - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoOptionsFactory

Uses the configured parameters to create a MongoOptions instance.

createSnapshotDocument(DomainEventMessage<?>, Serializer) - Method in class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

Returns a Mongo document for given snapshot event.

createSnapshotDocument(DomainEventMessage<?>, Serializer) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.DocumentPerCommitStorageStrategy

createSnapshotDocument(DomainEventMessage<?>, Serializer) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.DocumentPerEventStorageStrategy

createTailToken(MongoCollection<Document>) - Method in class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

createTailToken() - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoEventStorageEngine

createTailToken(MongoCollection<Document>) - Method in interface org.axonframework.mongo.eventsourcing.eventstore.StorageStrategy

Creates a token that is at the tail of an event stream - that tracks events from the beginning of time.

createTokenAt(Instant) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoEventStorageEngine

D

database() - Method in class org.axonframework.mongo.AbstractMongoTemplate

Returns a reference to the Database with the configured database name.

DBObjectHierarchicalStreamReader - Class in org.axonframework.mongo.serialization

HierarchicalStreamReader implementation that reads from a Mongo DBObject structure that has been created using the DBObjectHierarchicalStreamWriter.

DBObjectHierarchicalStreamReader(DBObject) - Constructor for class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamReader

Initialize the reader to read the structure of the given root DBObject.

DBObjectHierarchicalStreamWriter - Class in org.axonframework.mongo.serialization

HierarchicalStreamWriter implementation that writes objects into a MongoDB DBObject structure.

DBObjectHierarchicalStreamWriter(DBObject) - Constructor for class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamWriter

Initialize the writer to write the object structure to the given root DBObject.

DBObjectToStringContentTypeConverter - Class in org.axonframework.mongo.serialization

ContentTypeConverter implementation that converts a DBObject structure into a String containing its Binary JSON representation.

DBObjectToStringContentTypeConverter() - Constructor for class org.axonframework.mongo.serialization.DBObjectToStringContentTypeConverter

DBObjectXStreamSerializer - Class in org.axonframework.mongo.serialization

XStream based serializer implementation that serializes objects into a Binary JSON structure.

DBObjectXStreamSerializer() - Constructor for class org.axonframework.mongo.serialization.DBObjectXStreamSerializer

Initialize the serializer with UTF-8 character set and a default XStream serializer.

DBObjectXStreamSerializer(XStream) - Constructor for class org.axonframework.mongo.serialization.DBObjectXStreamSerializer

Initialize the serializer using the UTF-8 character set.

DBObjectXStreamSerializer(XStream, RevisionResolver) - Constructor for class org.axonframework.mongo.serialization.DBObjectXStreamSerializer

Initialize the serializer using the UTF-8 character set.

DBObjectXStreamSerializer(Charset) - Constructor for class org.axonframework.mongo.serialization.DBObjectXStreamSerializer

Initialize the serializer using the given charset.

DBObjectXStreamSerializer(Charset, XStream) - Constructor for class org.axonframework.mongo.serialization.DBObjectXStreamSerializer

Initialize the serializer using the given charset and xStream instance.

DBObjectXStreamSerializer(Charset, XStream, RevisionResolver) - Constructor for class org.axonframework.mongo.serialization.DBObjectXStreamSerializer

Initialize the serializer using the given charset, xStream and revisionResolver instance.

DBObjectXStreamSerializer(Charset, XStream, RevisionResolver, Converter) - Constructor for class org.axonframework.mongo.serialization.DBObjectXStreamSerializer

Initialize the serializer using the given charset and xStream instance.

DefaultMongoTemplate - Class in org.axonframework.mongo

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

DefaultMongoTemplate(MongoClient) - Constructor for class org.axonframework.mongo.DefaultMongoTemplate

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

DefaultMongoTemplate(MongoClient, String) - Constructor for class org.axonframework.mongo.DefaultMongoTemplate

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

DefaultMongoTemplate - Class in org.axonframework.mongo.eventhandling.saga.repository

Deprecated.

Use DefaultMongoTemplate instead.

DefaultMongoTemplate(MongoClient) - Constructor for class org.axonframework.mongo.eventhandling.saga.repository.DefaultMongoTemplate

Deprecated.

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

DefaultMongoTemplate(MongoClient, String, String) - Constructor for class org.axonframework.mongo.eventhandling.saga.repository.DefaultMongoTemplate

Deprecated.

Creates a template connecting to given mongo instance, and loads sagas in the collection with given sagasCollectionName, in a database with given databaseName.

DefaultMongoTemplate - Class in org.axonframework.mongo.eventsourcing.eventstore

Deprecated.

Use DefaultMongoTemplate instead.

DefaultMongoTemplate(MongoClient) - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.DefaultMongoTemplate

Deprecated.

Initializes the MongoTemplate using the given mongo for database access, using default database and collection names.

DefaultMongoTemplate(MongoClient, String, String, String) - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.DefaultMongoTemplate

Deprecated.

Creates a template connecting to given mongo instance, and loads events in the collection with given domainEventsCollectionName and snapshot events from snapshotEventsCollectionName, in a database with given databaseName.

deleteSaga(Class<?>, String, Set<AssociationValue>) - Method in class org.axonframework.mongo.eventhandling.saga.repository.MongoSagaStore

deleteSnapshots(MongoCollection<Document>, String, long) - Method in class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

deleteSnapshots(MongoCollection<Document>, String, long) - Method in interface org.axonframework.mongo.eventsourcing.eventstore.StorageStrategy

Delete all snapshots of the aggregate with given aggregateIdentifier from the given snapshotCollection, whose sequence number is lower than the given sequenceNumber.

DocumentPerCommitStorageStrategy - Class in org.axonframework.mongo.eventsourcing.eventstore.documentpercommit

Implementation of a Mongo StorageStrategy that stores one Document per commit of a batch of events.

DocumentPerCommitStorageStrategy() - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.DocumentPerCommitStorageStrategy

Initializes a DocumentPerCommitStorageStrategy with default event entry and commit entry configuration.

DocumentPerCommitStorageStrategy(CommitEntryConfiguration) - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.DocumentPerCommitStorageStrategy

Initializes a DocumentPerCommitStorageStrategy with default event entry and given commitEntryConfiguration.

DocumentPerCommitStorageStrategy(EventEntryConfiguration, CommitEntryConfiguration, Duration) - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.DocumentPerCommitStorageStrategy

Initializes a DocumentPerCommitStorageStrategy with given eventConfiguration and commitEntryConfiguration.

DocumentPerEventStorageStrategy - Class in org.axonframework.mongo.eventsourcing.eventstore.documentperevent

Implementation of a StorageStrategy that stores one Document per EventMessage.

DocumentPerEventStorageStrategy() - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.DocumentPerEventStorageStrategy

Initializes a DocumentPerEventStorageStrategy with default configuration.

DocumentPerEventStorageStrategy(EventEntryConfiguration, Duration) - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.DocumentPerEventStorageStrategy

Initializes a DocumentPerEventStorageStrategy with given eventConfiguration.

DocumentToStringContentTypeConverter - Class in org.axonframework.mongo.serialization

ContentTypeConverter implementation that converts a BSON Document structure into a String containing its JSON representation.

DocumentToStringContentTypeConverter() - Constructor for class org.axonframework.mongo.serialization.DocumentToStringContentTypeConverter

doDeserialize(SerializedObject, XStream) - Method in class org.axonframework.mongo.serialization.DBObjectXStreamSerializer

doSerialize(Object, Class<T>, XStream) - Method in class org.axonframework.mongo.serialization.DBObjectXStreamSerializer

E

endNode() - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamWriter

ensureIndexes(MongoCollection<Document>, MongoCollection<Document>) - Method in class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

ensureIndexes(MongoCollection<Document>, MongoCollection<Document>) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.DocumentPerCommitStorageStrategy

ensureIndexes() - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoEventStorageEngine

Deprecated.

This method is now called by the constructor instead of the dependency injection framework running the @PostConstruct. i.e. You no longer have to call it manually if you don't use a dependency injection framework.

ensureIndexes(MongoCollection<Document>, MongoCollection<Document>) - Method in interface org.axonframework.mongo.eventsourcing.eventstore.StorageStrategy

Ensure that the correct indexes are in place.

ensureIndexes() - Method in class org.axonframework.mongo.eventsourcing.tokenstore.MongoTokenStore

Deprecated.

This method is now called by the constructor instead of the dependency injection framework running the @PostConstruct. i.e. You no longer have to call it manually if you don't use a dependency injection framework.

equals(Object) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoTrackingToken

eventCollection() - Method in class org.axonframework.mongo.DefaultMongoTemplate

eventCollection() - Method in class org.axonframework.mongo.eventhandling.saga.repository.DefaultMongoTemplate

Deprecated.

eventCollection() - Method in class org.axonframework.mongo.eventsourcing.eventstore.DefaultMongoTemplate

Deprecated.

Returns a reference to the collection containing the events.

eventCollection() - Method in interface org.axonframework.mongo.MongoTemplate

Returns a reference to the collection containing the events.

eventConfiguration() - Method in class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

Returns the EventEntryConfiguration that configures how event entries are to be stored.

EventEntry - Class in org.axonframework.mongo.eventsourcing.eventstore.documentperevent

Implementation of a serialized event message that can be used to create a Mongo document.

EventEntry(DomainEventMessage<?>, Serializer) - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntry

Constructor used to create a new event entry to store in Mongo.

EventEntry(Document, EventEntryConfiguration) - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntry

Creates a new EventEntry based on data provided by Mongo.

EventEntryConfiguration - Class in org.axonframework.mongo.eventsourcing.eventstore.documentperevent

Implementation of a StorageStrategy that stores one Document per commit of a list of events.

EventEntryConfiguration.Builder - Class in org.axonframework.mongo.eventsourcing.eventstore.documentperevent

eventIdentifierProperty() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration

Get the name of the property with the identifier of the event.

eventsProperty() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.CommitEntryConfiguration

Returns the name of the property containing the array of event entries.

expectedSourceType() - Method in class org.axonframework.mongo.serialization.DBObjectToStringContentTypeConverter

expectedSourceType() - Method in class org.axonframework.mongo.serialization.DocumentToStringContentTypeConverter

expectedSourceType() - Method in class org.axonframework.mongo.serialization.StringToDBObjectContentTypeConverter

extendClaim(String, int) - Method in class org.axonframework.mongo.eventsourcing.tokenstore.MongoTokenStore

extractEvents(Document) - Method in class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

Retrieves event data from the given Mongo object.

extractEvents(Document) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.DocumentPerCommitStorageStrategy

extractEvents(Document) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.DocumentPerEventStorageStrategy

extractHighestSequenceNumber(Document) - Method in class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

Extract the highest sequence number known from the entry represented by the given document.

extractHighestSequenceNumber(Document) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.DocumentPerCommitStorageStrategy

extractSnapshot(Document) - Method in class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

Retrieves snapshot event data from the given Mongo object.

extractSnapshot(Document) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.DocumentPerCommitStorageStrategy

extractSnapshot(Document) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.DocumentPerEventStorageStrategy

F

fetchDomainEvents(String, long, int) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoEventStorageEngine

fetchSegments(String) - Method in class org.axonframework.mongo.eventsourcing.tokenstore.MongoTokenStore

fetchToken(String, int) - Method in class org.axonframework.mongo.eventsourcing.tokenstore.MongoTokenStore

fetchTrackedEvents(TrackingToken, int) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoEventStorageEngine

findDomainEvents(MongoCollection<Document>, String, long, int) - Method in class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

findDomainEvents(MongoCollection<Document>, String, long, int) - Method in interface org.axonframework.mongo.eventsourcing.eventstore.StorageStrategy

Returns a batch of events for an aggregate with given aggregateIdentifier and a sequence number equal or higher than the given firstSequenceNumber.

findLastSnapshot(MongoCollection<Document>, String) - Method in class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

findLastSnapshot(MongoCollection<Document>, String) - Method in interface org.axonframework.mongo.eventsourcing.eventstore.StorageStrategy

Finds the entry containing the last snapshot event for an aggregate with given aggregateIdentifier in the given collection.

findSagas(Class<?>, AssociationValue) - Method in class org.axonframework.mongo.eventhandling.saga.repository.MongoSagaStore

findTrackedEvents(MongoCollection<Document>, TrackingToken, int) - Method in class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

findTrackedEvents(MongoCollection<Document>, TrackingToken, int) - Method in interface org.axonframework.mongo.eventsourcing.eventstore.StorageStrategy

Returns a batch of tracked events with a tracking token above the given lastToken.

firstSequenceNumberProperty() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.CommitEntryConfiguration

Returns the name of the property containing the sequence number of the first event entry.

firstTimestampProperty() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.CommitEntryConfiguration

Returns the name of the property containing the timestamp of the first event entry of the commit.

flush() - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamWriter

fromDBObject(DBObject) - Static method in class org.axonframework.mongo.serialization.BSONNode

Constructrs a BSONNode structure from the given DBObject structure.

G

getAggregateIdentifier() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntry

getAssociationValues() - Method in class org.axonframework.mongo.eventhandling.saga.repository.SagaEntry

Get a set of all the Saga's associations.

getAttribute(String) - Method in class org.axonframework.mongo.serialization.BSONNode

Returns the value of the attribute with given name.

getAttribute(String) - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamReader

getAttribute(int) - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamReader

getAttributeCount() - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamReader

getAttributeName(int) - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamReader

getAttributeNames() - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamReader

getConnectionsPerHost() - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoOptionsFactory

Getter for connectionsPerHost.

getConnectionTimeout() - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoOptionsFactory

Connection time out in milli seconds for doing something in mongo.

getDefault() - Static method in class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.CommitEntryConfiguration

Returns the default CommitEntryConfiguration.

getDefault() - Static method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration

Returns the default EventEntryConfiguration.

getEventIdentifier() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntry

getEvents() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.CommitEntry

Returns the event entries stored as part of this commit.

getKnownEventIds() - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoTrackingToken

Returns an Iterable with all known identifiers of events tracked before and including this token.

getMaxWaitTime() - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoOptionsFactory

get the maximum time a blocked thread that waits for a connection should wait.

getMetaData() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntry

getName() - Method in class org.axonframework.mongo.serialization.BSONNode

Returns the name of the current node

getNodeName() - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamReader

getPayload() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntry

getSaga(Serializer) - Method in class org.axonframework.mongo.eventhandling.saga.repository.SagaEntry

Returns the Saga instance stored in this entry.

getSagaId() - Method in class org.axonframework.mongo.eventhandling.saga.repository.SagaEntry

Get the identifier of this Saga.

getSequenceNumber() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntry

getSocketTimeOut() - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoOptionsFactory

Getter for the socket timeout.

getThreadsAllowedToBlockForConnectionMultiplier() - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoOptionsFactory

Getter for the amount of threads that block in relation to the amount of possible connections.

getTimestamp() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntry

getTimestamp() - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoTrackingToken

Get the timestamp of the last event tracked by this token.

getTrackedEvents() - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoTrackingToken

Gets tracked events.

getType() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntry

getValue() - Method in class org.axonframework.mongo.serialization.BSONNode

Returns the value of the current node

getValue() - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamReader

H

hashCode() - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoTrackingToken

hasMoreChildren() - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamReader

I

initializeTokenSegments(String, int) - Method in class org.axonframework.mongo.eventsourcing.tokenstore.MongoTokenStore

initializeTokenSegments(String, int, TrackingToken) - Method in class org.axonframework.mongo.eventsourcing.tokenstore.MongoTokenStore

insertSaga(Class<?>, String, Object, TrackingToken, Set<AssociationValue>) - Method in class org.axonframework.mongo.eventhandling.saga.repository.MongoSagaStore

L

lastSequenceNumberFor(MongoCollection<Document>, String) - Method in class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

lastSequenceNumberFor(String) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoEventStorageEngine

lastSequenceNumberFor(MongoCollection<Document>, String) - Method in interface org.axonframework.mongo.eventsourcing.eventstore.StorageStrategy

Return the last known sequence number for an Aggregate with given aggregateIdentifier, whose Events are stored in the given eventsCollection.

lastSequenceNumberProperty() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.CommitEntryConfiguration

Returns the name of the property containing the sequence number of the last event entry.

lastTimestampProperty() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentpercommit.CommitEntryConfiguration

Returns the name of the property containing the timestamp of the last event entry of the commit.

loadSaga(Class<S>, String) - Method in class org.axonframework.mongo.eventhandling.saga.repository.MongoSagaStore

lowerBound(TrackingToken) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoTrackingToken

M

metaDataProperty() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration

Get the name of the property with the metadata.

MongoEventStorageEngine - Class in org.axonframework.mongo.eventsourcing.eventstore

EventStorageEngine implementation that uses Mongo to store and fetch events.

MongoEventStorageEngine(MongoTemplate) - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.MongoEventStorageEngine

Initializes an EventStorageEngine that uses Mongo to store and load events.

MongoEventStorageEngine(Serializer, EventUpcaster, MongoTemplate, StorageStrategy) - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.MongoEventStorageEngine

Initializes an EventStorageEngine that uses Mongo to store and load events.

MongoEventStorageEngine(Serializer, EventUpcaster, Serializer, MongoTemplate, StorageStrategy) - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.MongoEventStorageEngine

Initializes an EventStorageEngine that uses Mongo to store and load events.

MongoEventStorageEngine(Serializer, EventUpcaster, Integer, MongoTemplate, StorageStrategy) - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.MongoEventStorageEngine

Initializes an EventStorageEngine that uses Mongo to store and load events.

MongoEventStorageEngine(Serializer, EventUpcaster, Serializer, Integer, MongoTemplate, StorageStrategy) - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.MongoEventStorageEngine

Initializes an EventStorageEngine that uses Mongo to store and load events.

MongoEventStorageEngine(Serializer, EventUpcaster, PersistenceExceptionResolver, Serializer, Integer, MongoTemplate, StorageStrategy) - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.MongoEventStorageEngine

Initializes an EventStorageEngine that uses Mongo to store and load events.

MongoFactory - Class in org.axonframework.mongo.eventsourcing.eventstore

Convenience class for creating Mongo instances.

MongoFactory() - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.MongoFactory

MongoOptionsFactory - Class in org.axonframework.mongo.eventsourcing.eventstore

Factory class used to create a MongoOptions instance.

MongoOptionsFactory() - Constructor for class org.axonframework.mongo.eventsourcing.eventstore.MongoOptionsFactory

Default constructor for the factory that initializes the defaults.

MongoSagaStore - Class in org.axonframework.mongo.eventhandling.saga.repository

Implementations of the SagaRepository that stores Sagas and their associations in a Mongo Database.

MongoSagaStore(MongoTemplate) - Constructor for class org.axonframework.mongo.eventhandling.saga.repository.MongoSagaStore

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

MongoSagaStore(MongoTemplate, Serializer) - Constructor for class org.axonframework.mongo.eventhandling.saga.repository.MongoSagaStore

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

MongoTemplate - Interface in org.axonframework.mongo

Template object providing access to the collections necessary for the Mongo based components.

MongoTokenStore - Class in org.axonframework.mongo.eventsourcing.tokenstore

An implementation of TokenStore that allows you store and retrieve tracking tokens with MongoDB.

MongoTokenStore(MongoTemplate, Serializer) - Constructor for class org.axonframework.mongo.eventsourcing.tokenstore.MongoTokenStore

Creates a MongoTokenStore with a default claim timeout of 10 seconds, a default owner identifier and a default content type.

MongoTokenStore(MongoTemplate, Serializer, TemporalAmount, String, Class<?>) - Constructor for class org.axonframework.mongo.eventsourcing.tokenstore.MongoTokenStore

Creates a MongoTokenStore by using the given values.

MongoTrackingToken - Class in org.axonframework.mongo.eventsourcing.eventstore

Tracking token implementation produced by the MongoEventStorageEngine to keep track of the position in an event stream.

moveDown() - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamReader

moveUp() - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamReader

O

of(Instant, String) - Static method in class org.axonframework.mongo.eventsourcing.eventstore.MongoTrackingToken

Returns a new instance of a MongoTrackingToken with given timestamp, eventIdentifier and sequenceNumber for the initial event in a stream.

of(Instant, Map<String, Long>) - Static method in class org.axonframework.mongo.eventsourcing.eventstore.MongoTrackingToken

Returns a new instance of MongoTrackingToken with given timestamp and given trackedEvents.

ORDER_ASC - Static variable in class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

The value to pass to Mongo to fetch documents in ascending order.

ORDER_DESC - Static variable in class org.axonframework.mongo.eventsourcing.eventstore.AbstractMongoEventStorageStrategy

The value to pass to Mongo to fetch documents in descending order.

org.axonframework.mongo - package org.axonframework.mongo

org.axonframework.mongo.eventhandling.saga.repository - package org.axonframework.mongo.eventhandling.saga.repository

org.axonframework.mongo.eventsourcing.eventstore - package org.axonframework.mongo.eventsourcing.eventstore

org.axonframework.mongo.eventsourcing.eventstore.documentpercommit - package org.axonframework.mongo.eventsourcing.eventstore.documentpercommit

org.axonframework.mongo.eventsourcing.eventstore.documentperevent - package org.axonframework.mongo.eventsourcing.eventstore.documentperevent

org.axonframework.mongo.eventsourcing.tokenstore - package org.axonframework.mongo.eventsourcing.tokenstore

org.axonframework.mongo.serialization - package org.axonframework.mongo.serialization

P

payloadProperty() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration

Get the name of the property with the payload data.

payloadRevisionProperty() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration

Get the name of the property with the payload revision.

payloadTypeProperty() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration

Get the name of the property with the payload type.

Q

queryByIdentifier(String) - Static method in class org.axonframework.mongo.eventhandling.saga.repository.SagaEntry

Returns the Mongo Query to find a Saga based on its identifier.

R

readSnapshotData(String) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoEventStorageEngine

registerConverters(ChainingConverter) - Method in class org.axonframework.mongo.serialization.DBObjectXStreamSerializer

releaseClaim(String, int) - Method in class org.axonframework.mongo.eventsourcing.tokenstore.MongoTokenStore

S

sagaCollection() - Method in class org.axonframework.mongo.DefaultMongoTemplate

sagaCollection() - Method in class org.axonframework.mongo.eventhandling.saga.repository.DefaultMongoTemplate

Deprecated.

sagaCollection() - Method in class org.axonframework.mongo.eventsourcing.eventstore.DefaultMongoTemplate

Deprecated.

sagaCollection() - Method in interface org.axonframework.mongo.MongoTemplate

Returns a reference to the collection containing the saga instances.

SagaEntry<T> - Class in org.axonframework.mongo.eventhandling.saga.repository

Java representation of sagas stored in a mongo instance

SagaEntry(String, T, Set<AssociationValue>, Serializer) - Constructor for class org.axonframework.mongo.eventhandling.saga.repository.SagaEntry

Constructs a new SagaEntry for the given saga.

SagaEntry(Document) - Constructor for class org.axonframework.mongo.eventhandling.saga.repository.SagaEntry

Initializes a Saga entry using a DBObject containing the Mongo Document

sequenceNumberProperty() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration

Get the name of the property with the aggregate sequence number of the event.

setAttribute(String, String) - Method in class org.axonframework.mongo.serialization.BSONNode

Sets an attribute to this node.

setConnectionsPerHost(int) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoOptionsFactory

Setter for the connections per host that are allowed.

setConnectionTimeout(int) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoOptionsFactory

Setter for the connection time out.

setMaxWaitTime(int) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoOptionsFactory

Set the max wait time for a blocked thread in milli seconds.

setMongoAddresses(List<ServerAddress>) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoFactory

Provide a list of ServerAddress objects to use for locating the Mongo replica set.

setMongoOptions(MongoClientOptions) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoFactory

Provide an instance of MongoOptions to be used for the connections.

setSocketTimeOut(int) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoOptionsFactory

Setter for the socket time out.

setThreadsAllowedToBlockForConnectionMultiplier(int) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoOptionsFactory

Set the multiplier for the amount of threads to block in relation to the maximum amount of connections.

setValue(String) - Method in class org.axonframework.mongo.serialization.BSONNode

Sets the value of this node.

setValue(String) - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamWriter

setWriteConcern(WriteConcern) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoFactory

Provided a write concern to be used by the mongo instance.

snapshotCollection() - Method in class org.axonframework.mongo.DefaultMongoTemplate

snapshotCollection() - Method in class org.axonframework.mongo.eventhandling.saga.repository.DefaultMongoTemplate

Deprecated.

snapshotCollection() - Method in class org.axonframework.mongo.eventsourcing.eventstore.DefaultMongoTemplate

Deprecated.

Returns a reference to the collection containing the snapshot events.

snapshotCollection() - Method in interface org.axonframework.mongo.MongoTemplate

Returns a reference to the collection containing the snapshot events.

startNode(String) - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamWriter

startNode(String, Class) - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamWriter

StorageStrategy - Interface in org.axonframework.mongo.eventsourcing.eventstore

Interface towards the mechanism that prescribes the structure in which events are stored in the Event Store.

storeSnapshot(DomainEventMessage<?>, Serializer) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoEventStorageEngine

storeToken(TrackingToken, String, int) - Method in class org.axonframework.mongo.eventsourcing.tokenstore.MongoTokenStore

StringToDBObjectContentTypeConverter - Class in org.axonframework.mongo.serialization

ContentTypeConverter implementation that converts a String containing its Binary JSON representation into a DBObject structure.

StringToDBObjectContentTypeConverter() - Constructor for class org.axonframework.mongo.serialization.StringToDBObjectContentTypeConverter

T

targetType() - Method in class org.axonframework.mongo.serialization.DBObjectToStringContentTypeConverter

targetType() - Method in class org.axonframework.mongo.serialization.DocumentToStringContentTypeConverter

targetType() - Method in class org.axonframework.mongo.serialization.StringToDBObjectContentTypeConverter

timestampProperty() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration

Get the name of the property with the timestamp of the event.

toString() - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoTrackingToken

trackingTokensCollection() - Method in class org.axonframework.mongo.DefaultMongoTemplate

trackingTokensCollection() - Method in class org.axonframework.mongo.eventhandling.saga.repository.DefaultMongoTemplate

Deprecated.

trackingTokensCollection() - Method in class org.axonframework.mongo.eventsourcing.eventstore.DefaultMongoTemplate

Deprecated.

trackingTokensCollection() - Method in interface org.axonframework.mongo.MongoTemplate

Returns a reference to the collection containing the Tracking Tokens.

typeProperty() - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration

Get the name of the property with the aggregate type.

U

underlyingReader() - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamReader

underlyingWriter() - Method in class org.axonframework.mongo.serialization.DBObjectHierarchicalStreamWriter

updateSaga(Class<?>, String, Object, TrackingToken, AssociationValues) - Method in class org.axonframework.mongo.eventhandling.saga.repository.MongoSagaStore

upperBound(TrackingToken) - Method in class org.axonframework.mongo.eventsourcing.eventstore.MongoTrackingToken

W

withAggregateIdentifierProperty(String) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration.Builder

withDomainEventsCollection(String) - Method in class org.axonframework.mongo.DefaultMongoTemplate

withEventIdentifierProperty(String) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration.Builder

withMetaDataProperty(String) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration.Builder

withPayloadProperty(String) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration.Builder

withPayloadRevisionProperty(String) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration.Builder

withPayloadTypeProperty(String) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration.Builder

withSagasCollection(String) - Method in class org.axonframework.mongo.DefaultMongoTemplate

withSequenceNumberProperty(String) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration.Builder

withSnapshotCollection(String) - Method in class org.axonframework.mongo.DefaultMongoTemplate

withTimestampProperty(String) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration.Builder

withTrackingTokenCollection(String) - Method in class org.axonframework.mongo.DefaultMongoTemplate

withTypeProperty(String) - Method in class org.axonframework.mongo.eventsourcing.eventstore.documentperevent.EventEntryConfiguration.Builder

A B C D E F G H I L M O P Q R S T U W