public interface ReplicatedEventQuery
extends akka.persistence.query.scaladsl.ReadJournal, akka.persistence.query.javadsl.ReadJournal
| Modifier and Type | Method and Description |
|---|---|
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.
|
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)
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.
persistenceId - (undocumented)fromDc - (undocumented)sequenceNr - (undocumented)akka.persistence.cassandra.session.scaladsl.CassandraSession session()