Package akka.actor.dungeon
Interface Dispatch
-
public interface DispatchINTERNAL 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()booleanhasMessages()Dispatchinit(boolean sendSupervise, MailboxType mailboxType)Initialize this cell, i.e.DispatchinitWithFailure(java.lang.Throwable failure)booleanisTerminated()akka.dispatch.Mailboxmailbox()intnumberOfMessages()voidrestart(java.lang.Throwable cause)voidresume(java.lang.Throwable causedByFailure)voidsendMessage(Envelope msg)voidsendSystemMessage(SystemMessage message)EnvelopeserializeAndDeserialize(Envelope envelope)java.lang.ObjectserializeAndDeserializePayload(java.lang.Object obj)Dispatchstart()Start this cell, i.e.voidstop()voidsuspend()akka.dispatch.MailboxswapMailbox(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)
-
-