public class CallingThreadDispatcherQueues
extends java.lang.Object
implements akka.actor.Extension
Constructor and Description |
---|
CallingThreadDispatcherQueues() |
Modifier and Type | Method and Description |
---|---|
static CallingThreadDispatcherQueues |
createExtension(akka.actor.ExtendedActorSystem system) |
protected void |
gatherFromAllOtherQueues(CallingThreadMailbox mbox,
akka.dispatch.MessageQueue own) |
static CallingThreadDispatcherQueues$ |
lookup() |
protected void |
registerQueue(CallingThreadMailbox mbox,
akka.dispatch.MessageQueue q) |
protected void |
unregisterQueues(CallingThreadMailbox mbox) |
public static CallingThreadDispatcherQueues$ lookup()
public static CallingThreadDispatcherQueues createExtension(akka.actor.ExtendedActorSystem system)
protected void registerQueue(CallingThreadMailbox mbox, akka.dispatch.MessageQueue q)
protected void unregisterQueues(CallingThreadMailbox mbox)
protected void gatherFromAllOtherQueues(CallingThreadMailbox mbox, akka.dispatch.MessageQueue own)