t

akka.persistence.query.javadsl

PersistenceIdsQuery

trait PersistenceIdsQuery extends ReadJournal

A plugin may optionally support this query by implementing this interface.

Source
PersistenceIdsQuery.scala
Linear Supertypes
ReadJournal, AnyRef, Any
Known Subclasses
LeveldbReadJournal
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PersistenceIdsQuery
  2. ReadJournal
  3. AnyRef
  4. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def persistenceIds(): Source[String, NotUsed]

    Query all PersistentActor identifiers, i.e.

    Query all PersistentActor identifiers, i.e. as defined by the persistenceId of the PersistentActor.

    The stream is not completed when it reaches the end of the currently used persistenceIds, but it continues to push new persistenceIds when new persistent actors are created. Corresponding query that is completed when it reaches the end of the currently currently used persistenceIds is provided by CurrentPersistenceIdsQuery#currentPersistenceIds.