public class CassandraReplicatedEventQuery extends akka.persistence.cassandra.query.scaladsl.CassandraReadJournal implements ReplicatedEventQuery, CassandraReplicatedStatements
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.
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 and Description |
|---|
CassandraReplicatedEventQuery(akka.actor.ExtendedActorSystem system,
com.typesafe.config.Config _config,
java.lang.String pluginId) |
| 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.
|
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, writeTagScanningclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcreateNotificationKeyspace, createNotificationTable, executeAsyncCreateNotificationKeyspace, executeCreateKeyspaceAndTables, notificationTableName, readNotification, super$executeCreateKeyspaceAndTables, writeNotificationaddTagsToMessagesTable, createKeyspace, createMetadataTable, createTable, createTagScanningTable, createTagsProgressTable, createTagsTable, deleteDeletedTo, deleteMessage, deleteMessages, insertDeletedTo, selectDeletedTo, selectHighestSequenceNr, selectMessages, selectTagPidSequenceNr, selectTagProgress, selectTagProgressForPersistenceId, selectTagScanningForPersistenceId, tableName, updateMessagePayloadAndTags, updateMessagePayloadInTagView, writeInUse, writeMessage, writeTagProgress, writeTags, writeTagScanningpublic CassandraReplicatedEventQuery(akka.actor.ExtendedActorSystem system,
com.typesafe.config.Config _config,
java.lang.String pluginId)
public static final java.lang.String Identifier()
CassandraReplicatedEventQuery to be used with
akka.persistence.query.PersistenceQuery#readJournalFor.public MultiDcConfig multiDcConfig()
multiDcConfig in interface CassandraReplicatedStatementspublic akka.persistence.cassandra.session.scaladsl.CassandraSession session()
session in interface ReplicatedEventQuerysession in class akka.persistence.cassandra.query.scaladsl.CassandraReadJournalpublic akka.persistence.cassandra.journal.CassandraJournalConfig config()
config in interface akka.persistence.cassandra.journal.CassandraStatementsconfig in class akka.persistence.cassandra.query.scaladsl.CassandraReadJournalpublic 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)
ReplicatedEventQueryReplicatedEntity (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.
replicatedEvents in interface ReplicatedEventQuerypersistenceId - (undocumented)fromDc - (undocumented)sequenceNr - (undocumented)public akka.persistence.PersistentRepr mapEvent(akka.persistence.PersistentRepr persistentRepr)
mapEvent in class akka.persistence.cassandra.query.scaladsl.CassandraReadJournalpersistentRepr - (undocumented)