public abstract static class ReadSideProcessor.ReadSideHandler<Event extends AggregateEvent<Event>>
extends Object
Constructor and Description |
---|
ReadSideHandler() |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.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.
|
java.util.concurrent.CompletionStage<Offset> |
prepare(AggregateEventTag<Event> tag)
Prepare this processor.
|
public java.util.concurrent.CompletionStage<akka.Done> globalPrepare()
public java.util.concurrent.CompletionStage<Offset> prepare(AggregateEventTag<Event> tag)
tag
- The tag to get the offset for.