Packages

package javadsl

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. class CassandraReadJournal extends ReadJournal with PersistenceIdsQuery with CurrentPersistenceIdsQuery with EventsByPersistenceIdQuery with CurrentEventsByPersistenceIdQuery with EventsByTagQuery with CurrentEventsByTagQuery

    Java API: akka.persistence.query.javadsl.ReadJournal implementation for Cassandra.

    Java API: akka.persistence.query.javadsl.ReadJournal implementation for Cassandra.

    It is retrieved with:

    CassandraReadJournal queries =
      PersistenceQuery.get(system).getReadJournalFor(CassandraReadJournal.class, CassandraReadJournal.Identifier());

    Corresponding Scala API is in akka.persistence.cassandra.query.scaladsl.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. See reference.conf.

Value Members

  1. object CassandraReadJournal

Ungrouped