akka.persistence.multidc.testkit

Class InterruptableCassandraReplicatedEventQuery

java.lang.Object

akka.persistence.cassandra.query.scaladsl.CassandraReadJournal

akka.persistence.multidc.internal.CassandraReplicatedEventQuery

akka.persistence.multidc.testkit.InterruptableCassandraReplicatedEventQuery

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

public class InterruptableCassandraReplicatedEventQuery
extends CassandraReplicatedEventQuery

INTERNAL API: It is retrieved with:

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

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
InterruptableCassandraReplicatedEventQuery(akka.actor.ExtendedActorSystem system, com.typesafe.config.Config config, java.lang.String pluginId)

Method Summary

Modifier and Type	Method and Description
void	addErrorFilter(java.lang.String key, scala.Function1<ReplicatedEventEnvelope,scala.Option<java.lang.Throwable>> f)
void	addErrorFilter(java.lang.String key, int maxErrors, scala.Function1<ReplicatedEventEnvelope,scala.Option<java.lang.Throwable>> f)
void	disableReplication(java.lang.String fromDc)
void	enableAll()
void	enableReplication(java.lang.String fromDc)
void	removeAllErrorFilters()
void	removeErrorFilter(java.lang.String key)
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.

Methods inherited from class akka.persistence.multidc.internal.CassandraReplicatedEventQuery

config, Identifier, mapEvent, multiDcConfig, session

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

InterruptableCassandraReplicatedEventQuery

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

Method Detail

addErrorFilter

public void addErrorFilter(java.lang.String key,
                           scala.Function1<ReplicatedEventEnvelope,scala.Option<java.lang.Throwable>> f)

addErrorFilter

public void addErrorFilter(java.lang.String key,
                           int maxErrors,
                           scala.Function1<ReplicatedEventEnvelope,scala.Option<java.lang.Throwable>> f)

disableReplication

public void disableReplication(java.lang.String fromDc)

enableAll

public void enableAll()

enableReplication

public void enableReplication(java.lang.String fromDc)

removeAllErrorFilters

public void removeAllErrorFilters()

removeErrorFilter

public void removeErrorFilter(java.lang.String key)

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

Overrides:

replicatedEvents in class CassandraReplicatedEventQuery

Parameters:

persistenceId - (undocumented)

fromDc - (undocumented)

sequenceNr - (undocumented)

Returns:

(undocumented)