Class PersistenceTestKitReadJournal
- java.lang.Object
-
- akka.persistence.testkit.query.javadsl.PersistenceTestKitReadJournal
-
- All Implemented Interfaces:
CurrentEventsByPersistenceIdQuery
,CurrentEventsByTagQuery
,EventsByPersistenceIdQuery
,ReadJournal
,CurrentEventsBySliceQuery
public final class PersistenceTestKitReadJournal extends java.lang.Object implements ReadJournal, EventsByPersistenceIdQuery, CurrentEventsByPersistenceIdQuery, CurrentEventsByTagQuery, CurrentEventsBySliceQuery
-
-
Constructor Summary
Constructors Constructor Description PersistenceTestKitReadJournal(PersistenceTestKitReadJournal delegate)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Source<EventEnvelope,NotUsed>
currentEventsByPersistenceId(java.lang.String persistenceId, long fromSequenceNr, long toSequenceNr)
Same type of query asEventsByPersistenceIdQuery.eventsByPersistenceId(java.lang.String, long, long)
but the event stream is completed immediately when it reaches the end of the "result set".<Event> Source<EventEnvelope<Event>,NotUsed>
currentEventsBySlices(java.lang.String entityType, int minSlice, int maxSlice, Offset offset)
Same type of query asEventsBySliceQuery.eventsBySlices
but the event stream is completed immediately when it reaches the end of the "result set".Source<EventEnvelope,NotUsed>
currentEventsByTag(java.lang.String tag, Offset offset)
Same type of query asEventsByTagQuery.eventsByTag(java.lang.String, akka.persistence.query.Offset)
but the event stream is completed immediately when it reaches the end of the "result set".Source<EventEnvelope,NotUsed>
eventsByPersistenceId(java.lang.String persistenceId, long fromSequenceNr, long toSequenceNr)
Query events for a specificPersistentActor
identified bypersistenceId
.static java.lang.String
Identifier()
int
sliceForPersistenceId(java.lang.String persistenceId)
java.util.List<Pair<java.lang.Integer,java.lang.Integer>>
sliceRanges(int numberOfRanges)
-
-
-
Constructor Detail
-
PersistenceTestKitReadJournal
public PersistenceTestKitReadJournal(PersistenceTestKitReadJournal delegate)
-
-
Method Detail
-
Identifier
public static java.lang.String Identifier()
-
eventsByPersistenceId
public Source<EventEnvelope,NotUsed> eventsByPersistenceId(java.lang.String persistenceId, long fromSequenceNr, long toSequenceNr)
Description copied from interface:EventsByPersistenceIdQuery
Query events for a specificPersistentActor
identified bypersistenceId
.You can retrieve a subset of all events by specifying
fromSequenceNr
andtoSequenceNr
or use0L
andLong.MAX_VALUE
respectively to retrieve all events. The query will return all the events inclusive of thefromSequenceNr
andtoSequenceNr
values.The returned event stream should be ordered by sequence number.
The stream is not completed when it reaches the end of the currently stored events, but it continues to push new events when new events are persisted. Corresponding query that is completed when it reaches the end of the currently stored events is provided by
CurrentEventsByPersistenceIdQuery.currentEventsByPersistenceId(java.lang.String, long, long)
.- Specified by:
eventsByPersistenceId
in interfaceEventsByPersistenceIdQuery
-
currentEventsByPersistenceId
public Source<EventEnvelope,NotUsed> currentEventsByPersistenceId(java.lang.String persistenceId, long fromSequenceNr, long toSequenceNr)
Description copied from interface:CurrentEventsByPersistenceIdQuery
Same type of query asEventsByPersistenceIdQuery.eventsByPersistenceId(java.lang.String, long, long)
but the event stream is completed immediately when it reaches the end of the "result set". Events that are stored after the query is completed are not included in the event stream.- Specified by:
currentEventsByPersistenceId
in interfaceCurrentEventsByPersistenceIdQuery
-
currentEventsByTag
public Source<EventEnvelope,NotUsed> currentEventsByTag(java.lang.String tag, Offset offset)
Description copied from interface:CurrentEventsByTagQuery
Same type of query asEventsByTagQuery.eventsByTag(java.lang.String, akka.persistence.query.Offset)
but the event stream is completed immediately when it reaches the end of the "result set". Depending on journal implementation, this may mean all events up to when the query is started, or it may include events that are persisted while the query is still streaming results. For eventually consistent stores, it may only include all events up to some point before the query is started.- Specified by:
currentEventsByTag
in interfaceCurrentEventsByTagQuery
-
currentEventsBySlices
public <Event> Source<EventEnvelope<Event>,NotUsed> currentEventsBySlices(java.lang.String entityType, int minSlice, int maxSlice, Offset offset)
Description copied from interface:CurrentEventsBySliceQuery
Same type of query asEventsBySliceQuery.eventsBySlices
but the event stream is completed immediately when it reaches the end of the "result set". Depending on journal implementation, this may mean all events up to when the query is started, or it may include events that are persisted while the query is still streaming results. For eventually consistent stores, it may only include all events up to some point before the query is started.- Specified by:
currentEventsBySlices
in interfaceCurrentEventsBySliceQuery
-
sliceForPersistenceId
public int sliceForPersistenceId(java.lang.String persistenceId)
- Specified by:
sliceForPersistenceId
in interfaceCurrentEventsBySliceQuery
-
sliceRanges
public java.util.List<Pair<java.lang.Integer,java.lang.Integer>> sliceRanges(int numberOfRanges)
- Specified by:
sliceRanges
in interfaceCurrentEventsBySliceQuery
-
-