akka.persistence.multidc.internal

Interface ReplicatedEventQuery

All Superinterfaces:

akka.persistence.query.javadsl.ReadJournal

All Known Implementing Classes:

CassandraReplicatedEventQuery, InterruptableCassandraReplicatedEventQuery

public interface ReplicatedEventQuery
extends akka.persistence.query.scaladsl.ReadJournal, akka.persistence.query.javadsl.ReadJournal

INTERNAL API: A ReadJournal implementation may optionally support querying for replicated events by implementing this trait.

Method Summary

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.

Method Detail

replicatedEvents

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.

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.

Parameters:

persistenceId - (undocumented)

fromDc - (undocumented)

sequenceNr - (undocumented)

Returns:

(undocumented)

session

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

Data Access Object for arbitrary queries or updates.

Returns:

(undocumented)