akka.persistence.multidc.internal

Class CassandraReplicatedEventJournal

java.lang.Object

akka.persistence.cassandra.journal.CassandraJournal

akka.persistence.multidc.internal.CassandraReplicatedEventJournal

All Implemented Interfaces:

akka.actor.Actor, akka.actor.NoSerializationVerificationNeeded, akka.persistence.cassandra.journal.CassandraRecovery, akka.persistence.cassandra.journal.CassandraStatements, akka.persistence.cassandra.journal.CassandraTagRecovery, akka.persistence.cassandra.journal.TaggedPreparedStatements, akka.persistence.journal.AsyncRecovery, akka.persistence.journal.AsyncWriteJournal, akka.persistence.journal.WriteJournalBase, CassandraReplicatedStatements

public class CassandraReplicatedEventJournal
extends akka.persistence.cassandra.journal.CassandraJournal
implements CassandraReplicatedStatements

INTERNAL API: Akka Persistence journal plugin for replication of events across multiple data centers. Extends the ordinary CassandraJournal in akka-persistence-cassandra.

Nested Class Summary

Nested classes/interfaces inherited from class akka.persistence.cassandra.journal.CassandraJournal

akka.persistence.cassandra.journal.CassandraJournal.CleanupCommand, akka.persistence.cassandra.journal.CassandraJournal.DeleteAllEvents, akka.persistence.cassandra.journal.CassandraJournal.DeleteAllEvents$, akka.persistence.cassandra.journal.CassandraJournal.DeleteFinished, akka.persistence.cassandra.journal.CassandraJournal.DeleteFinished$, akka.persistence.cassandra.journal.CassandraJournal.EventDeserializer, akka.persistence.cassandra.journal.CassandraJournal.Init$, akka.persistence.cassandra.journal.CassandraJournal.MessageId, akka.persistence.cassandra.journal.CassandraJournal.MessageId$, akka.persistence.cassandra.journal.CassandraJournal.PartitionInfo, akka.persistence.cassandra.journal.CassandraJournal.PartitionInfo$, akka.persistence.cassandra.journal.CassandraJournal.PendingDelete, akka.persistence.cassandra.journal.CassandraJournal.PendingDelete$, akka.persistence.cassandra.journal.CassandraJournal.Serialized, akka.persistence.cassandra.journal.CassandraJournal.Serialized$, akka.persistence.cassandra.journal.CassandraJournal.SerializedAtomicWrite, akka.persistence.cassandra.journal.CassandraJournal.SerializedAtomicWrite$, akka.persistence.cassandra.journal.CassandraJournal.SerializedMeta, akka.persistence.cassandra.journal.CassandraJournal.SerializedMeta$, akka.persistence.cassandra.journal.CassandraJournal.WriteFinished, akka.persistence.cassandra.journal.CassandraJournal.WriteFinished$

Nested classes/interfaces inherited from interface akka.persistence.journal.AsyncWriteJournal

akka.persistence.journal.AsyncWriteJournal.Desequenced, akka.persistence.journal.AsyncWriteJournal.Desequenced$, akka.persistence.journal.AsyncWriteJournal.Resequencer

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
CassandraReplicatedEventJournal(com.typesafe.config.Config cfg)

Method Summary

Modifier and Type	Method and Description
scala.concurrent.Future<scala.collection.immutable.Seq<scala.util.Try<scala.runtime.BoxedUnit>>>	asyncWriteMessages(scala.collection.immutable.Seq<akka.persistence.AtomicWrite> messages)
MultiDcConfig	multiDcConfig()

Methods inherited from class akka.persistence.cassandra.journal.CassandraJournal

adaptFromJournal, adaptToJournal, addTagsToMessagesTable, akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, akka$persistence$cassandra$journal$CassandraJournal$$asyncDeleteMessages$1, akka$persistence$cassandra$journal$CassandraJournal$$delete, akka$persistence$cassandra$journal$CassandraJournal$$deleteDeletedToSeqNr, akka$persistence$cassandra$journal$CassandraJournal$$deleteRetryPolicy, akka$persistence$cassandra$journal$CassandraJournal$$execute, akka$persistence$cassandra$journal$CassandraJournal$$executeBatch, akka$persistence$cassandra$journal$CassandraJournal$$extractTagWrites, akka$persistence$cassandra$journal$CassandraJournal$$find$1, akka$persistence$cassandra$journal$CassandraJournal$$logicalAndPhysicalDelete$1, akka$persistence$cassandra$journal$CassandraJournal$$minSequenceNr, akka$persistence$cassandra$journal$CassandraJournal$$partitionInfo, akka$persistence$cassandra$journal$CassandraJournal$$pendingDeletes, akka$persistence$cassandra$journal$CassandraJournal$$physicalDelete$1, akka$persistence$cassandra$journal$CassandraJournal$$serialize$1, akka$persistence$cassandra$journal$CassandraJournal$$writeInProgress, akka$persistence$cassandra$journal$CassandraJournal$$writeMessages, akka$persistence$cassandra$journal$CassandraRecovery$_setter_$eventDeserializer_$eq, akka$persistence$cassandra$journal$CassandraTagRecovery$_setter_$akka$persistence$cassandra$journal$CassandraTagRecovery$$timeout_$eq, akka$persistence$cassandra$journal$CassandraTagRecovery$$timeout, akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$breaker_$eq, akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$config_$eq, akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$extension_$eq, akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$publish_$eq, akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterMaxOldWriters_$eq, akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterMode_$eq, akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterWindowSize_$eq, akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$resequencer_$eq, akka$persistence$journal$AsyncWriteJournal$_setter_$receiveWriteJournal_$eq, akka$persistence$journal$AsyncWriteJournal$$breaker, akka$persistence$journal$AsyncWriteJournal$$config, akka$persistence$journal$AsyncWriteJournal$$extension, akka$persistence$journal$AsyncWriteJournal$$publish, akka$persistence$journal$AsyncWriteJournal$$replayFilterMaxOldWriters, akka$persistence$journal$AsyncWriteJournal$$replayFilterMode, akka$persistence$journal$AsyncWriteJournal$$replayFilterWindowSize, akka$persistence$journal$AsyncWriteJournal$$resequencer, akka$persistence$journal$AsyncWriteJournal$$resequencerCounter_$eq, akka$persistence$journal$AsyncWriteJournal$$resequencerCounter, akka$persistence$journal$WriteJournalBase$_setter_$akka$persistence$journal$WriteJournalBase$$eventAdapters_$eq, akka$persistence$journal$WriteJournalBase$_setter_$persistence_$eq, akka$persistence$journal$WriteJournalBase$$eventAdapters, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, asyncDeleteMessagesTo, asyncFindHighestSequenceNr, asyncHighestDeletedSequenceNumber, asyncReadHighestSequenceNr, asyncReadHighestSequenceNrInternal, asyncReadLowestSequenceNr, asyncReplayMessages, config, context, createKeyspace, createMetadataTable, createTable, createTagScanningTable, createTagsProgressTable, createTagsTable, deleteDeletedTo, deleteMessage, deleteMessages, ec, eventDeserializer, executeCreateKeyspaceAndTables, generateUUID, insertDeletedTo, log, lookupTagProgress, materializer, persistence, postRestart, postStop, preparedDeleteMessages, preparedInsertDeletedTo, preparedSelectDeletedTo, preparedSelectHighestSequenceNr, preparedSelectMessages, preparedSelectTagProgress, preparedSelectTagProgressForPersistenceId, preparedSelectTagScanningForPersistenceId, preparedWriteInUse, preparedWriteMessage, preparedWriteMessageWithMeta, preparedWriteTagScanning, preparedWriteToTagProgress, preparedWriteToTagViewWithMeta, preparedWriteToTagViewWithoutMeta, preparePersistentBatch, preRestart, preStart, queries, readRetryPolicy, receive, receivePluginInternal, receiveWriteJournal, selectDeletedTo, selectHighestSequenceNr, selectMessages, selectTagPidSequenceNr, selectTagProgress, selectTagProgressForPersistenceId, selectTagScanningForPersistenceId, self, sender, sendMissingTagWriteRaw, sendPersistentActorStarting, sendPreSnapshotTagWrites, sendWriteFinished, serialization, session, setTagProgress, someReadConsistency, someReadRetryPolicy, supervisorStrategy, tableName, tagScanningStartingSequenceNr, tagWrites, unhandled, updateMessagePayloadAndTags, updateMessagePayloadInTagView, writeInUse, writeMessage, writeRetryPolicy, writeTagProgress, writeTags, writeTagScanning

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.persistence.multidc.internal.CassandraReplicatedStatements

createNotificationKeyspace, createNotificationTable, executeAsyncCreateNotificationKeyspace, executeCreateKeyspaceAndTables, notificationTableName, readNotification, super$executeCreateKeyspaceAndTables, writeNotification

Methods inherited from interface akka.persistence.cassandra.journal.CassandraStatements

addTagsToMessagesTable, config, createKeyspace, createMetadataTable, createTable, createTagScanningTable, createTagsProgressTable, createTagsTable, deleteDeletedTo, deleteMessage, deleteMessages, insertDeletedTo, selectDeletedTo, selectHighestSequenceNr, selectMessages, selectTagPidSequenceNr, selectTagProgress, selectTagProgressForPersistenceId, selectTagScanningForPersistenceId, tableName, updateMessagePayloadAndTags, updateMessagePayloadInTagView, writeInUse, writeMessage, writeTagProgress, writeTags, writeTagScanning

Constructor Detail

CassandraReplicatedEventJournal

public CassandraReplicatedEventJournal(com.typesafe.config.Config cfg)

Method Detail

asyncWriteMessages

public scala.concurrent.Future<scala.collection.immutable.Seq<scala.util.Try<scala.runtime.BoxedUnit>>> asyncWriteMessages(scala.collection.immutable.Seq<akka.persistence.AtomicWrite> messages)

Specified by:

asyncWriteMessages in interface akka.persistence.journal.AsyncWriteJournal

Overrides:

asyncWriteMessages in class akka.persistence.cassandra.journal.CassandraJournal

multiDcConfig

public MultiDcConfig multiDcConfig()

Specified by:

multiDcConfig in interface CassandraReplicatedStatements