public abstract static class ReadSideProcessor.ReadSideHandler<Event extends AggregateEvent<Event>> extends Object
Constructor and Description |
---|
ReadSideHandler() |
Modifier and Type | Method and Description |
---|---|
CompletionStage<akka.Done> |
globalPrepare()
Prepare the database for all processors.
|
abstract akka.stream.javadsl.Flow<akka.japi.Pair<Event,Offset>,akka.Done,?> |
handle()
Flow to handle the events.
|
CompletionStage<Offset> |
prepare(AggregateEventTag<Event> tag)
Prepare this processor.
|
public CompletionStage<akka.Done> globalPrepare()
public CompletionStage<Offset> prepare(AggregateEventTag<Event> tag)
tag
- The tag to get the offset for.