Package akka.persistence.typed.scaladsl

Interface ReplicationInterceptor<State,Event>

public interface ReplicationInterceptor<State,Event>

Method Summary

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

Method Detail

intercept

scala.concurrent.Future<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: