org.eligosource.eventsourced.journal.common

support

package support

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. support
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

  1. trait AsynchronousWriteReplaySupport extends Actor

  2. trait SynchronousWriteReplaySupport extends Actor

Value Members

  1. def resetPromiseActorRef(initialCounter: Long)(p: (Message) ⇒ Unit): (Message) ⇒ Unit

    Decorates p to reset Message.senderRef.

    Decorates p to reset Message.senderRef. The senderRef is reset if the event message

    • has a sequenceNr < initialCounter and
    • has a senderRef of type PromiseActorRef

    Otherwise, the senderRef is not changed. This ensures that references to temporary system actors from previous application runs are not resolved.

    initialCounter

    initial counter value after journal recovery.

    p

    event message handler.

    returns

    decorated event message handler.

Inherited from AnyRef

Inherited from Any

Ungrouped