Package org.apache.pekko.persistence.typed.internal

Interface StashManagement<C,E,S>

public interface StashManagement<C,E,S>
INTERNAL API: Stash management for persistent behaviors

  • Method Details

    • context

      ActorContext<InternalProtocol> context()

    • isInternalStashEmpty

      boolean isInternalStashEmpty()

    • isUnstashAllInProgress

      boolean isUnstashAllInProgress()

    • logStashMessage

      void logStashMessage(InternalProtocol msg, StashBuffer<InternalProtocol> buffer)

    • logUnstashAll

      void logUnstashAll()

    • logUnstashMessage

      void logUnstashMessage(StashBuffer<InternalProtocol> buffer)

    • setup

      org.apache.pekko.persistence.typed.internal.BehaviorSetup<C,E,S> setup()

    • stash

      void stash(InternalProtocol msg, StashBuffer<InternalProtocol> buffer)

    • stashInternal

      Behavior<InternalProtocol> stashInternal(InternalProtocol msg)
      Stash a command to the internal stash buffer, which is used while waiting for persist to be completed.

    • stashState

      org.apache.pekko.persistence.typed.internal.StashState stashState()

    • stashUser

      void stashUser(InternalProtocol msg)
      Stash a command to the user stash buffer, which is used when Stash effect is used.

    • tryUnstashOne

      Behavior<InternalProtocol> tryUnstashOne(Behavior<InternalProtocol> behavior)
      tryUnstashOne is called at the end of processing each command, published event, or when persist is completed

    • unstashAll

      void unstashAll()
      Subsequent tryUnstashOne will drain the user stash buffer before using the internal stash buffer. It will unstash as many commands as are in the buffer when unstashAll was called, i.e. if subsequent commands stash more, those will not be unstashed until unstashAll is called again.