Package org.apache.pekko.persistence.query.javadsl

Interface PersistenceIdsQuery

All Superinterfaces:
ReadJournal
All Known Implementing Classes:
LeveldbReadJournal
public interface PersistenceIdsQuery extends ReadJournal
A plugin may optionally support this query by implementing this interface.

  • Method Summary

    Modifier and Type
    Method
    Description
    Source<String,NotUsed>
    persistenceIds()
    Query all PersistentActor identifiers, i.e.

  • Method Details

    • persistenceIds

      Source<String,NotUsed> persistenceIds()
      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().