package scaladsl
Ordering
- Alphabetic
Visibility
- Public
- Protected
Type Members
- class CassandraReadJournal extends ReadJournal with PersistenceIdsQuery with CurrentPersistenceIdsQuery with EventsByPersistenceIdQuery with CurrentEventsByPersistenceIdQuery with EventsByTagQuery with CurrentEventsByTagQuery
Scala API
akka.persistence.query.scaladsl.ReadJournal
implementation for Cassandra.Scala API
akka.persistence.query.scaladsl.ReadJournal
implementation for Cassandra.It is retrieved with:
val queries = PersistenceQuery(system).readJournalFor[CassandraReadJournal](CassandraReadJournal.Identifier)
Corresponding Java API is in akka.persistence.cassandra.query.javadsl.CassandraReadJournal.
Configuration settings can be defined in the configuration section with the absolute path corresponding to the identifier, which is
"akka.persistence.cassandra.query"
for the default CassandraReadJournal#Identifier. Seereference.conf
.
Value Members
- object CassandraReadJournal