akka.persistence.multidc.internal

Class CassandraReplicatedEventQuery

java.lang.Object

akka.persistence.cassandra.query.scaladsl.CassandraReadJournal

akka.persistence.multidc.internal.CassandraReplicatedEventQuery

All Implemented Interfaces:

akka.persistence.cassandra.journal.CassandraStatements, CassandraReplicatedStatements, ReplicatedEventQuery, akka.persistence.query.scaladsl.CurrentEventsByPersistenceIdQuery, akka.persistence.query.scaladsl.CurrentEventsByTagQuery, akka.persistence.query.scaladsl.CurrentPersistenceIdsQuery, akka.persistence.query.scaladsl.EventsByPersistenceIdQuery, akka.persistence.query.scaladsl.EventsByTagQuery, akka.persistence.query.scaladsl.PersistenceIdsQuery, akka.persistence.query.scaladsl.ReadJournal

Direct Known Subclasses:

InterruptableCassandraReplicatedEventQuery

public class CassandraReplicatedEventQuery
extends akka.persistence.cassandra.query.scaladsl.CassandraReadJournal
implements ReplicatedEventQuery, CassandraReplicatedStatements

INTERNAL API

Scala API akka.persistence.query.scaladsl.ReadJournal implementation of replicated events for Cassandra.

It is retrieved with:

 val queries = PersistenceQuery(system).readJournalFor[CassandraReplicatedEventQuery](CassandraReplicatedEventQuery.Identifier)
 

It extends CassandraReadJournal from akka-persistence-cassandra and thereby supports all queries provided by that plugin.

Configuration settings can be defined in the configuration section with the absolute path corresponding to the identifier, which is "cassandra-query-journal-multi-dc" for the default Identifier(). See reference.conf.

Nested Class Summary

Nested classes/interfaces inherited from class akka.persistence.cassandra.query.scaladsl.CassandraReadJournal

akka.persistence.cassandra.query.scaladsl.CassandraReadJournal.CombinedEventsByPersistenceIdStmts, akka.persistence.cassandra.query.scaladsl.CassandraReadJournal.CombinedEventsByPersistenceIdStmts$, akka.persistence.cassandra.query.scaladsl.CassandraReadJournal.EventByTagStatements, akka.persistence.cassandra.query.scaladsl.CassandraReadJournal.EventByTagStatements$

Constructor Summary

Constructors

Constructor and Description
CassandraReplicatedEventQuery(akka.actor.ExtendedActorSystem system, com.typesafe.config.Config _config, java.lang.String pluginId)

Method Summary

Modifier and Type	Method and Description
akka.persistence.cassandra.journal.CassandraJournalConfig	config() This must be overridden because it is used by the CassandraStatements
static java.lang.String	Identifier() The default identifier for CassandraReplicatedEventQuery to be used with akka.persistence.query.PersistenceQuery#readJournalFor.
akka.persistence.PersistentRepr	mapEvent(akka.persistence.PersistentRepr persistentRepr) INTERNAL API: Internal hook for amending the event payload.
MultiDcConfig	multiDcConfig()
akka.stream.scaladsl.Source<ReplicatedEventEnvelope,scala.concurrent.Future<akka.persistence.cassandra.query.EventsByPersistenceIdStage.Control>>	replicatedEvents(java.lang.String persistenceId, java.lang.String fromDc, long sequenceNr) Query replicated events for a ReplicatedEntity (persistenceId) from given data center.
akka.persistence.cassandra.session.scaladsl.CassandraSession	session() Data Access Object for arbitrary queries or updates.

Methods inherited from class akka.persistence.cassandra.query.scaladsl.CassandraReadJournal

addTagsToMessagesTable, akka$persistence$cassandra$query$scaladsl$CassandraReadJournal$$ec, akka$persistence$cassandra$query$scaladsl$CassandraReadJournal$$eventsByTagDeserializer, akka$persistence$cassandra$query$scaladsl$CassandraReadJournal$$getSession$1, akka$persistence$cassandra$query$scaladsl$CassandraReadJournal$$getSession$2, akka$persistence$cassandra$query$scaladsl$CassandraReadJournal$$log, akka$persistence$cassandra$query$scaladsl$CassandraReadJournal$$materializer, akka$persistence$cassandra$query$scaladsl$CassandraReadJournal$$preparedSelectDeletedTo, akka$persistence$cassandra$query$scaladsl$CassandraReadJournal$$queryPluginConfig, akka$persistence$cassandra$query$scaladsl$CassandraReadJournal$$readRetryPolicy, akka$persistence$cassandra$query$scaladsl$CassandraReadJournal$$timestampFrom, akka$persistence$cassandra$query$scaladsl$CassandraReadJournal$$toEventEnvelope, akka$persistence$cassandra$query$scaladsl$CassandraReadJournal$$toEventEnvelopes, akka$persistence$cassandra$query$scaladsl$CassandraReadJournal$$writePluginConfig, calculateStartingTagPidSequenceNrs, combinedEventsByPersistenceIdStmts, combinedEventsByTagStmts, createFutureSource, createKeyspace, createMetadataTable, createSource, createTable, createTagScanningTable, createTagsProgressTable, createTagsTable, currentEventsByPersistenceId, currentEventsByTag, currentEventsByTagInternal, currentPersistenceIds, deleteDeletedTo, deleteMessage, deleteMessages, eventsByPersistenceId, eventsByPersistenceId, eventsByPersistenceId$default$11, eventsByPersistenceId$default$8, eventsByPersistenceId$default$9, eventsByPersistenceIdWithControl, eventsByPersistenceIdWithControl$default$4, eventsByTag, eventsByTagInternal, executeCreateKeyspaceAndTables, firstOffset, initialize, insertDeletedTo, offsetUuid, persistenceIds, selectDeletedTo, selectHighestSequenceNr, selectMessages, selectTagPidSequenceNr, selectTagProgress, selectTagProgressForPersistenceId, selectTagScanningForPersistenceId, tableName, tagViewScanner, timeBasedUUIDFrom, timestampFrom, updateMessagePayloadAndTags, updateMessagePayloadInTagView, writeInUse, writeMessage, 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, 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

CassandraReplicatedEventQuery

public CassandraReplicatedEventQuery(akka.actor.ExtendedActorSystem system,
                                     com.typesafe.config.Config _config,
                                     java.lang.String pluginId)

Method Detail

Identifier

public static final java.lang.String Identifier()

The default identifier for CassandraReplicatedEventQuery to be used with akka.persistence.query.PersistenceQuery#readJournalFor.

Returns:

(undocumented)

multiDcConfig

public MultiDcConfig multiDcConfig()

Specified by:

multiDcConfig in interface CassandraReplicatedStatements

session

public akka.persistence.cassandra.session.scaladsl.CassandraSession session()

Data Access Object for arbitrary queries or updates.

Specified by:

session in interface ReplicatedEventQuery

Overrides:

session in class akka.persistence.cassandra.query.scaladsl.CassandraReadJournal

Returns:

(undocumented)

config

public akka.persistence.cassandra.journal.CassandraJournalConfig config()

This must be overridden because it is used by the CassandraStatements

Specified by:

config in interface akka.persistence.cassandra.journal.CassandraStatements

Overrides:

config in class akka.persistence.cassandra.query.scaladsl.CassandraReadJournal

Returns:

(undocumented)

replicatedEvents

public akka.stream.scaladsl.Source<ReplicatedEventEnvelope,scala.concurrent.Future<akka.persistence.cassandra.query.EventsByPersistenceIdStage.Control>> replicatedEvents(java.lang.String persistenceId,
                                                                                                                                                                          java.lang.String fromDc,
                                                                                                                                                                          long sequenceNr)

Description copied from interface: ReplicatedEventQuery

Query replicated events for a ReplicatedEntity (persistenceId) from given data center.

The returned event stream is ordered by sequence number.

The stream is not completed when it reaches the end of the currently stored events, but it continues to push new events when new events are persisted/replicated.

Specified by:

replicatedEvents in interface ReplicatedEventQuery

Parameters:

persistenceId - (undocumented)

fromDc - (undocumented)

sequenceNr - (undocumented)

Returns:

(undocumented)

mapEvent

public akka.persistence.PersistentRepr mapEvent(akka.persistence.PersistentRepr persistentRepr)

INTERNAL API: Internal hook for amending the event payload. Called from all queries.

Overrides:

mapEvent in class akka.persistence.cassandra.query.scaladsl.CassandraReadJournal

Parameters:

persistentRepr - (undocumented)

Returns:

(undocumented)