t

akka.persistence.typed.javadsl

ReplicationInterceptor

trait ReplicationInterceptor[Event, State] extends AnyRef

Annotations
@FunctionalInterface()
Source
EventSourcedBehavior.scala
Linear Supertypes
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ReplicationInterceptor
  2. AnyRef
  3. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def intercept(state: State, event: Event, originReplica: ReplicaId, sequenceNumber: Long): [Done]

    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