MessageDispatcher

abstract def createMailbox(actor: ActorCell): Mailbox

Creates and returns a mailbox for the given actor.

abstract def dispatch(receiver: ActorCell, invocation: Envelope): Unit

Will be called when the dispatcher is to queue an invocation for execution

abstract def executeTask(invocation: TaskInvocation): Unit

abstract def id: String

Identifier of this dispatcher, corresponds to the full key of the dispatcher configuration.

abstract def registerForExecution(mbox: Mailbox, hasMessageHint: Boolean, hasSystemMessageHint: Boolean): Boolean

Suggest to register the provided mailbox for execution

abstract def shutdown(): Unit

Called one time every time an actor is detached from this dispatcher and this dispatcher has no actors left attached Must be idempotent

abstract def shutdownTimeout: Duration

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.

abstract def systemDispatch(receiver: ActorCell, invocation: SystemMessage): Unit

Will be called when the dispatcher is to queue an invocation for execution

abstract def throughput: Int

abstract def throughputDeadlineTime: Duration

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

final def attach(actor: ActorCell): Unit

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).

def clone(): AnyRef

final def detach(actor: ActorCell): Unit

Detaches the specified actor instance from this dispatcher

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

final def execute(runnable: Runnable): Unit

Submits the runnable for execution

def finalize(): Unit

final def getClass(): java.lang.Class[_]

def hashCode(): Int

def inhabitants: Long

final def isInstanceOf[T0]: Boolean

final val isThroughputDeadlineTimeDefined: Boolean

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

val prerequisites: DispatcherPrerequisites

def register(actor: ActorCell): Unit

If you override it, you must call it.

def reportFailure(t: Throwable): Unit

Failed tasks should call reportFailure to let the ExecutionContext log the problem or whatever is appropriate for the implementation.

def resume(actor: ActorCell): Unit

def suspend(actor: ActorCell): Unit

After the call to this method, the dispatcher mustn't begin any new message processing for the specified reference

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

def unregister(actor: ActorCell): Unit

If you override it, you must call it.

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit