Type Members

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

   Scala API org.apache.pekko.persistence.query.scaladsl.ReadJournal implementation for Cassandra.

   Scala API org.apache.pekko.persistence.query.scaladsl.ReadJournal implementation for Cassandra.

   It is retrieved with:

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

   Corresponding Java API is in pekko.persistence.cassandra.query.javadsl.CassandraReadJournal.

   Configuration settings can be defined in the configuration section with the absolute path corresponding to the identifier, which is "pekko.persistence.cassandra.query" for the default CassandraReadJournal#Identifier. See reference.conf.