|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.dispatch.MessageDispatcher
public abstract class MessageDispatcher
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface scala.concurrent.ExecutionContext |
---|
scala.concurrent.ExecutionContext.Implicits$ |
Constructor Summary | |
---|---|
MessageDispatcher(MessageDispatcherConfigurator configurator)
|
Method Summary | |
---|---|
java.lang.ThreadLocal<scala.collection.immutable.List<java.lang.Runnable>> |
_tasksLocal()
|
static Index<MessageDispatcher,ActorRef> |
actors()
|
void |
attach(akka.actor.ActorCell actor)
Attaches the specified actor instance to this dispatcher, which includes scheduling it to run for the first time (Create() is expected to have been enqueued by the ActorCell upon mailbox creation). |
boolean |
batchable(java.lang.Runnable runnable)
Override this to define which runnables will be batched. |
MessageDispatcherConfigurator |
configurator()
|
protected abstract akka.dispatch.Mailbox |
createMailbox(akka.actor.Cell actor,
MailboxType mailboxType)
Creates and returns a mailbox for the given actor. |
static boolean |
debug()
|
void |
detach(akka.actor.ActorCell actor)
Detaches the specified actor instance from this dispatcher |
protected abstract void |
dispatch(akka.actor.ActorCell receiver,
Envelope invocation)
Will be called when the dispatcher is to queue an invocation for execution |
EventStream |
eventStream()
|
void |
execute(java.lang.Runnable runnable)
|
protected abstract void |
executeTask(TaskInvocation invocation)
INTERNAL API |
abstract java.lang.String |
id()
Identifier of this dispatcher, corresponds to the full key of the dispatcher configuration. |
long |
inhabitants()
|
protected boolean |
isThroughputDeadlineTimeDefined()
INTERNAL API |
akka.dispatch.Mailboxes |
mailboxes()
|
static void |
printActors()
|
protected void |
register(akka.actor.ActorCell actor)
If you override it, you must call it. |
protected abstract boolean |
registerForExecution(akka.dispatch.Mailbox mbox,
boolean hasMessageHint,
boolean hasSystemMessageHint)
Suggest to register the provided mailbox for execution |
void |
reportFailure(java.lang.Throwable t)
|
static int |
RESCHEDULED()
|
protected void |
resume(akka.actor.ActorCell actor)
|
static int |
SCHEDULED()
|
protected abstract void |
shutdown()
Called one time every time an actor is detached from this dispatcher and this dispatcher has no actors left attached Must be idempotent |
protected abstract scala.concurrent.duration.FiniteDuration |
shutdownTimeout()
When the dispatcher no longer has any actors registered, how long will it wait until it shuts itself down, defaulting to your akka configs "akka.actor.default-dispatcher.shutdown-timeout" or default specified in reference.conf |
protected void |
suspend(akka.actor.ActorCell actor)
After the call to this method, the dispatcher mustn't begin any new message processing for the specified reference |
protected abstract void |
systemDispatch(akka.actor.ActorCell receiver,
akka.dispatch.sysmsg.SystemMessage invocation)
Will be called when the dispatcher is to queue an invocation for execution |
protected abstract int |
throughput()
INTERNAL API |
protected abstract scala.concurrent.duration.Duration |
throughputDeadlineTime()
INTERNAL API |
protected void |
unbatchedExecute(java.lang.Runnable r)
|
protected void |
unregister(akka.actor.ActorCell actor)
If you override it, you must call it. |
static int |
UNSCHEDULED()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface scala.concurrent.ExecutionContext |
---|
execute, prepare |
Constructor Detail |
---|
public MessageDispatcher(MessageDispatcherConfigurator configurator)
Method Detail |
---|
public static int UNSCHEDULED()
public static int SCHEDULED()
public static int RESCHEDULED()
public static final boolean debug()
public static Index<MessageDispatcher,ActorRef> actors()
public static void printActors()
public MessageDispatcherConfigurator configurator()
public akka.dispatch.Mailboxes mailboxes()
public EventStream eventStream()
public final long inhabitants()
protected abstract akka.dispatch.Mailbox createMailbox(akka.actor.Cell actor, MailboxType mailboxType)
public abstract java.lang.String id()
public final void attach(akka.actor.ActorCell actor)
public final void detach(akka.actor.ActorCell actor)
protected final void unbatchedExecute(java.lang.Runnable r)
public void reportFailure(java.lang.Throwable t)
reportFailure
in interface scala.concurrent.ExecutionContext
protected void register(akka.actor.ActorCell actor)
INTERNAL API
protected void unregister(akka.actor.ActorCell actor)
INTERNAL API
protected abstract scala.concurrent.duration.FiniteDuration shutdownTimeout()
INTERNAL API
protected void suspend(akka.actor.ActorCell actor)
protected void resume(akka.actor.ActorCell actor)
protected abstract void systemDispatch(akka.actor.ActorCell receiver, akka.dispatch.sysmsg.SystemMessage invocation)
INTERNAL API
protected abstract void dispatch(akka.actor.ActorCell receiver, Envelope invocation)
INTERNAL API
protected abstract boolean registerForExecution(akka.dispatch.Mailbox mbox, boolean hasMessageHint, boolean hasSystemMessageHint)
INTERNAL API
protected abstract int throughput()
protected abstract scala.concurrent.duration.Duration throughputDeadlineTime()
protected final boolean isThroughputDeadlineTimeDefined()
protected abstract void executeTask(TaskInvocation invocation)
protected abstract void shutdown()
INTERNAL API
public java.lang.ThreadLocal<scala.collection.immutable.List<java.lang.Runnable>> _tasksLocal()
public void execute(java.lang.Runnable runnable)
execute
in interface java.util.concurrent.Executor
public boolean batchable(java.lang.Runnable runnable)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |