Package akka.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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Source<java.lang.String,NotUsed>persistenceIds()Query allPersistentActoridentifiers, i.e.
-
-
-
Method Detail
-
persistenceIds
Source<java.lang.String,NotUsed> persistenceIds()
Query allPersistentActoridentifiers, i.e. as defined by thepersistenceIdof thePersistentActor.The stream is not completed when it reaches the end of the currently used
persistenceIds, but it continues to push newpersistenceIdswhen new persistent actors are created. Corresponding query that is completed when it reaches the end of the currently currently usedpersistenceIdsis provided byCurrentPersistenceIdsQuery.currentPersistenceIds().
-
-