Package akka.actor.dungeon
Interface Dispatch
-
public interface Dispatch
INTERNAL API
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
_mailboxDoNotCallMeDirectly_$eq(akka.dispatch.Mailbox x$1)
akka.dispatch.Mailbox
_preventPrivateUnusedErasure()
scala.PartialFunction<java.lang.Throwable,scala.runtime.BoxedUnit>
handleException()
boolean
hasMessages()
Dispatch
init(boolean sendSupervise, MailboxType mailboxType)
Initialize this cell, i.e.Dispatch
initWithFailure(java.lang.Throwable failure)
boolean
isTerminated()
akka.dispatch.Mailbox
mailbox()
int
numberOfMessages()
void
restart(java.lang.Throwable cause)
void
resume(java.lang.Throwable causedByFailure)
void
sendMessage(Envelope msg)
void
sendSystemMessage(SystemMessage message)
Envelope
serializeAndDeserialize(Envelope envelope)
java.lang.Object
serializeAndDeserializePayload(java.lang.Object obj)
Dispatch
start()
Start this cell, i.e.void
stop()
void
suspend()
akka.dispatch.Mailbox
swapMailbox(akka.dispatch.Mailbox newMailbox)
-
-
-
Method Detail
-
_mailboxDoNotCallMeDirectly_$eq
void _mailboxDoNotCallMeDirectly_$eq(akka.dispatch.Mailbox x$1)
-
_preventPrivateUnusedErasure
akka.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
akka.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)
-
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
akka.dispatch.Mailbox swapMailbox(akka.dispatch.Mailbox newMailbox)
-
-