Required nodes to connect to.
Optional authentication list. Defaults to List.empty.
Optional number of channels to open per node. Defaults to 10.
Optional name of the newly created {@see MongoDBSystem} actor, if needed
Optional mongoDB database name. Defaults to {@see DefaultDatabaseName}
Optional mongoDB collection name. Defaults to {@see DefaultCollectionName}
Optional GetLastError. Defaults to awaitJournalCommit = false, waitForReplicatedOn = None, fsync = false.
Optional journal actor name.
Optional journal actor dispatcher name.
Timeout for journal initialization. During initialization the highest stored sequence number is loaded from the event message table.
Maximum number of event messages to keep in memory during replay.
Optional authentication list.
Optional authentication list. Defaults to List.empty.
Optional mongoDB collection name.
Optional mongoDB collection name. Defaults to {@see DefaultCollectionName}
Creates and starts a new journal using the settings of this configuration object.
Creates and starts a new journal using the settings of this configuration object.
Returns a new MongodbRactiveJournal
.
Returns a new MongodbRactiveJournal
.
Optional mongoDB database name.
Optional mongoDB database name. Defaults to {@see DefaultDatabaseName}
Optional journal actor dispatcher name.
Optional journal actor dispatcher name.
Timeout for journal initialization.
Timeout for journal initialization. During initialization the highest stored sequence number is loaded from the event message table.
Optional name of the newly created {@see MongoDBSystem} actor, if needed
Optional journal actor name.
Optional journal actor name.
Optional number of channels to open per node.
Optional number of channels to open per node. Defaults to 10.
Required nodes to connect to.
Make journal read only (e.
Make journal read only (e.g. offline snapshot)
Maximum number of event messages to keep in memory during replay.
Hadoop filesystem for storing snapshots.
Hadoop filesystem for storing snapshots.
Timeout for loading a snapshot.
Timeout for loading a snapshot.
Path where snapshots are stored on snapshotFilesystem
.
Path where snapshots are stored on snapshotFilesystem
. A relative path is relative to
snapshotFilesystem
's working directory.
Timeout for saving a snapshot.
Timeout for saving a snapshot.
Serializer for writing and reading snapshots.
Serializer for writing and reading snapshots.
Returns a new MongodbReactiveJournalProps
with specified list of authentications.
Returns a new MongodbReactiveJournalProps
with specified collection name.
Returns a new MongodbReactiveJournalProps
with specified database name.
Returns a new MongodbReactiveJournalProps
with specified journal actor dispatcher name.
Returns a new MongodbReactiveJournalProps
with specified init timeout.
Returns a new MongodbReactiveJournalProps
with specified journal actor name.
Returns a new MongodbReactiveJournalProps
with specified journal actor name.
Returns a new MongodbReactiveJournalProps
with specified number of channels per node
Java API.
Returns a new MongodbReactiveJournalProps
with specified replay chunk size.
Java API.
Java API.
Java API.
Java API.
Java API.
Java API.
Java API.
Java API.
Java API.
Optional GetLastError.
Optional GetLastError. Defaults to awaitJournalCommit = false, waitForReplicatedOn = None, fsync = false.
Configuration object for an Mongodb/Reactive based journal.
Journal actors can be created from a configuration object as follows:
Required nodes to connect to.
Optional authentication list. Defaults to List.empty.
Optional number of channels to open per node. Defaults to 10.
Optional name of the newly created {@see MongoDBSystem} actor, if needed
Optional mongoDB database name. Defaults to {@see DefaultDatabaseName}
Optional mongoDB collection name. Defaults to {@see DefaultCollectionName}
Optional GetLastError. Defaults to awaitJournalCommit = false, waitForReplicatedOn = None, fsync = false.
Optional journal actor name.
Optional journal actor dispatcher name.
Timeout for journal initialization. During initialization the highest stored sequence number is loaded from the event message table.
Maximum number of event messages to keep in memory during replay.