Package akka.persistence.typed.javadsl

Interface ReplicationInterceptor<Event,State>

public interface ReplicationInterceptor<Event,State>

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.CompletionStage<Done>	intercept(State state, Event event, ReplicaId originReplica, long sequenceNumber)

Method Detail

intercept

java.util.concurrent.CompletionStage<Done> intercept(State state,
                                                     Event event,
                                                     ReplicaId originReplica,
                                                     long sequenceNumber)

Parameters:

state - Current state

event - The replicated event

originReplica - The replica where the event came from

sequenceNumber - The local sequence number the event will get when persisted

Returns: