Type Members

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

   Java API: org.apache.pekko.persistence.query.javadsl.ReadJournal implementation for Cassandra.

   Java API: org.apache.pekko.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 pekko.persistence.cassandra.query.scaladsl.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.