Package org.apache.pekko.actor.dungeon

Interface Dispatch

public interface Dispatch
INTERNAL API

  • Method Details

    • _mailboxDoNotCallMeDirectly_$eq

      void _mailboxDoNotCallMeDirectly_$eq(org.apache.pekko.dispatch.Mailbox x$1)

    • _preventPrivateUnusedErasure

      org.apache.pekko.dispatch.Mailbox _preventPrivateUnusedErasure()

    • handleException

      scala.PartialFunction<Throwable,scala.runtime.BoxedUnit> handleException()

    • hasMessages

      boolean hasMessages()

    • init

      Dispatch init(boolean sendSupervise, MailboxType mailboxType)
      Initialize this cell, i.e. set up mailboxes and supervision. The UID must be reasonably different from the previous UID of a possible actor with the same path, which can be achieved by using ThreadLocalRandom.current.nextInt().

    • initWithFailure

      Dispatch initWithFailure(Throwable failure)

    • isTerminated

      boolean isTerminated()

    • mailbox

      org.apache.pekko.dispatch.Mailbox mailbox()

    • numberOfMessages

      int numberOfMessages()

    • restart

      void restart(Throwable cause)

    • resume

      void resume(Throwable causedByFailure)

    • sendMessage

      void sendMessage(Envelope msg)

    • sendSystemMessage

      void sendSystemMessage(SystemMessage message)

    • serializeAndDeserialize

      Envelope serializeAndDeserialize(Envelope envelope)

    • serializeAndDeserializePayload

      Object serializeAndDeserializePayload(Object obj)

    • start

      Dispatch start()
      Start this cell, i.e. attach it to the dispatcher.

    • stop

      void stop()

    • suspend

      void suspend()

    • swapMailbox

      org.apache.pekko.dispatch.Mailbox swapMailbox(org.apache.pekko.dispatch.Mailbox newMailbox)