Package akka.persistence.query.scaladsl
Interface PersistenceIdsQuery
-
- All Superinterfaces:
ReadJournal
- All Known Implementing Classes:
LeveldbReadJournal
public interface PersistenceIdsQuery extends ReadJournal
Query allPersistentActor
identifiers, i.e. as defined by thepersistenceId
of thePersistentActor
.The stream is not completed when it reaches the end of the currently used
persistenceIds
, but it continues to push newpersistenceIds
when new persistent actors are created. Corresponding query that is completed when it reaches the end of the currently currently usedpersistenceIds
is provided byCurrentPersistenceIdsQuery.currentPersistenceIds()
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Source<java.lang.String,NotUsed>
persistenceIds()
-