Package org.apache.pekko.actor.dungeon

Interface Dispatch

  • public interface Dispatch
    INTERNAL API

    • Method Detail

      • _mailboxDoNotCallMeDirectly_$eq

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

      • _preventPrivateUnusedErasure

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

      • handleException

        scala.PartialFunction<java.lang.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​(java.lang.Throwable failure)

      • isTerminated

        boolean isTerminated()

      • mailbox

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

      • numberOfMessages

        int numberOfMessages()

      • restart

        void restart​(java.lang.Throwable cause)

      • resume

        void resume​(java.lang.Throwable causedByFailure)

      • sendMessage

        void sendMessage​(Envelope msg)

      • sendSystemMessage

        void sendSystemMessage​(SystemMessage message)

      • serializeAndDeserialize

        Envelope serializeAndDeserialize​(Envelope envelope)

      • serializeAndDeserializePayload

        java.lang.Object serializeAndDeserializePayload​(java.lang.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)