PersistentActor
identifiers, i.e.allPersistenceIds
is used for retrieving all persistenceIds
of all
persistent actors.allPersistenceIds
is used for retrieving all persistenceIds
of all
persistent actors.PersistentActor
identifiers, i.e.EventsByPersistenceIdQuery.eventsByPersistenceId(java.lang.String, long, long)
but the event stream is completed immediately when it reaches the end of
the "result set".LeveldbReadJournal.eventsByPersistenceId(java.lang.String, long, long)
but the event stream
is completed immediately when it reaches the end of the "result set".LeveldbReadJournal.eventsByPersistenceId(java.lang.String, long, long)
but the event stream
is completed immediately when it reaches the end of the "result set".EventsByPersistenceIdQuery.eventsByPersistenceId(java.lang.String, long, long)
but the event stream is completed immediately when it reaches the end of
the "result set".EventsByTagQuery.eventsByTag(java.lang.String, long)
but the event stream
is completed immediately when it reaches the end of the "result set".LeveldbReadJournal.eventsByTag(java.lang.String, long)
but the event stream
is completed immediately when it reaches the end of the "result set".LeveldbReadJournal.eventsByTag(java.lang.String, long)
but the event stream
is completed immediately when it reaches the end of the "result set".EventsByTagQuery.eventsByTag(java.lang.String, long)
but the event stream
is completed immediately when it reaches the end of the "result set".AllPersistenceIdsQuery.allPersistenceIds()
but the stream
is completed immediately when it reaches the end of the "result set".LeveldbReadJournal.allPersistenceIds()
but the stream
is completed immediately when it reaches the end of the "result set".LeveldbReadJournal.allPersistenceIds()
but the stream
is completed immediately when it reaches the end of the "result set".AllPersistenceIdsQuery.allPersistenceIds()
but the stream
is completed immediately when it reaches the end of the "result set".EventsByTagQuery
query, or similar queries.PersistentActor
identified by persistenceId
.eventsByPersistenceId
is used for retrieving events for a specific
PersistentActor
identified by persistenceId
.eventsByPersistenceId
is used for retrieving events for a specific
PersistentActor
identified by persistenceId
.PersistentActor
identified by persistenceId
.eventsByTag
is used for retrieving events that were marked with
a given tag, e.g.eventsByTag
is used for retrieving events that were marked with
a given tag, e.g.ReadJournal
specified by the given
read journal configuration entry.LeveldbReadJournal
to be used with
PersistenceQuery.getReadJournalFor(java.lang.Class<T>, java.lang.String)
.LeveldbReadJournal
to be used with
PersistenceQuery.getReadJournalFor(java.lang.Class<T>, java.lang.String)
.LeveldbReadJournal
to be used with
PersistenceQuery.readJournalFor(java.lang.String)
.LeveldbReadJournal
to be used with
PersistenceQuery.readJournalFor(java.lang.String)
.ReadJournal
implementation for the Java API.ReadJournal
implementation for LevelDB.ReadJournal
implementation for LevelDB.ReadJournal
specified by the given
read journal configuration entry.ReadJournal
implementation for the Scala API.