@ApiMayChange public class AkkaTaggerAdapter extends Object
Constructor and Description |
---|
AkkaTaggerAdapter() |
Modifier and Type | Method and Description |
---|---|
static <Command,Event extends AggregateEvent<Event>> |
fromLagom(akka.cluster.sharding.typed.javadsl.EntityContext<Command> entityContext,
AggregateEventTagger<Event> lagomTagger)
Adapts an existing Lagom
AggregateEventTagger to a function Function<Event,
Set<String>> as expected by Akka Persistence Typed EventSourcedBehavior.withTagger
API. |
public static <Command,Event extends AggregateEvent<Event>> Function<Event,Set<String>> fromLagom(akka.cluster.sharding.typed.javadsl.EntityContext<Command> entityContext, AggregateEventTagger<Event> lagomTagger)
AggregateEventTagger
to a function Function<Event,
Set<String>>
as expected by Akka Persistence Typed EventSourcedBehavior.withTagger
API.