abstract class MessageDispatcher extends AbstractMessageDispatcher with BatchingExecutor with ExecutionContextExecutor
- Alphabetic
- By Inheritance
- MessageDispatcher
- ExecutionContextExecutor
- ExecutionContext
- BatchingExecutor
- Executor
- AbstractMessageDispatcher
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new MessageDispatcher(configurator: MessageDispatcherConfigurator)
Abstract Value Members
- abstract def createMailbox(actor: Cell, mailboxType: MailboxType): Mailbox
Creates and returns a mailbox for the given actor.
Creates and returns a mailbox for the given actor.
- Attributes
- protected[pekko]
- abstract def dispatch(receiver: ActorCell, invocation: Envelope): Unit
Will be called when the dispatcher is to queue an invocation for execution
Will be called when the dispatcher is to queue an invocation for execution
INTERNAL API
- Attributes
- protected[pekko]
- abstract def executeTask(invocation: TaskInvocation): Unit
INTERNAL API
INTERNAL API
- Attributes
- protected[pekko]
- 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
Suggest to register the provided mailbox for execution
INTERNAL API
- Attributes
- protected[pekko]
- 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
Called one time every time an actor is detached from this dispatcher and this dispatcher has no actors left attached Must be idempotent
INTERNAL API
- Attributes
- protected[pekko]
- Annotations
- @InternalStableApi()
- abstract def shutdownTimeout: FiniteDuration
When the dispatcher no longer has any actors registered, how long will it wait until it shuts itself down, defaulting to your pekko configs "pekko.actor.default-dispatcher.shutdown-timeout" or default specified in reference.conf
When the dispatcher no longer has any actors registered, how long will it wait until it shuts itself down, defaulting to your pekko configs "pekko.actor.default-dispatcher.shutdown-timeout" or default specified in reference.conf
INTERNAL API
- Attributes
- protected[pekko]
- abstract def systemDispatch(receiver: ActorCell, invocation: SystemMessage): Unit
Will be called when the dispatcher is to queue an invocation for execution
Will be called when the dispatcher is to queue an invocation for execution
INTERNAL API
- Attributes
- protected[pekko]
- abstract def throughput: Int
INTERNAL API
INTERNAL API
- Attributes
- protected[pekko]
- abstract def throughputDeadlineTime: Duration
INTERNAL API
INTERNAL API
- Attributes
- protected[pekko]
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- def +(other: String): String
- Implicit
- This member is added by an implicit conversion from MessageDispatcher toany2stringadd[MessageDispatcher] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
- def ->[B](y: B): (MessageDispatcher, B)
- Implicit
- This member is added by an implicit conversion from MessageDispatcher toArrowAssoc[MessageDispatcher] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- 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 batchable(runnable: Runnable): Boolean
Override this to define which runnables will be batched.
Override this to define which runnables will be batched.
- Definition Classes
- BatchingExecutor
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- val configurator: MessageDispatcherConfigurator
- final def detach(actor: ActorCell): Unit
Detaches the specified actor instance from this dispatcher
- def ensuring(cond: (MessageDispatcher) => Boolean, msg: => Any): MessageDispatcher
- Implicit
- This member is added by an implicit conversion from MessageDispatcher toEnsuring[MessageDispatcher] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: (MessageDispatcher) => Boolean): MessageDispatcher
- Implicit
- This member is added by an implicit conversion from MessageDispatcher toEnsuring[MessageDispatcher] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: Boolean, msg: => Any): MessageDispatcher
- Implicit
- This member is added by an implicit conversion from MessageDispatcher toEnsuring[MessageDispatcher] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- def ensuring(cond: Boolean): MessageDispatcher
- Implicit
- This member is added by an implicit conversion from MessageDispatcher toEnsuring[MessageDispatcher] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- val eventStream: EventStream
- def execute(runnable: Runnable): Unit
- Definition Classes
- BatchingExecutor → Executor
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def inhabitants: Long
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final val isThroughputDeadlineTimeDefined: Boolean
INTERNAL API
INTERNAL API
- Attributes
- protected[pekko]
- val mailboxes: Mailboxes
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def register(actor: ActorCell): Unit
If you override it, you must call it.
If you override it, you must call it. But only ever once. See "attach" for only invocation.
INTERNAL API
- Attributes
- protected[pekko]
- def reportFailure(t: Throwable): Unit
- Definition Classes
- MessageDispatcher → ExecutionContext
- final def resubmitOnBlock: Boolean
- Attributes
- protected
- Definition Classes
- MessageDispatcher → BatchingExecutor
- def resume(actor: ActorCell): Unit
After the call to this method, the dispatcher must begin any new message processing for the specified reference
After the call to this method, the dispatcher must begin any new message processing for the specified reference
- Attributes
- protected[pekko]
- def suspend(actor: ActorCell): Unit
After the call to this method, the dispatcher mustn't begin any new message processing for the specified reference
After the call to this method, the dispatcher mustn't begin any new message processing for the specified reference
- Attributes
- protected[pekko]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def unbatchedExecute(r: Runnable): Unit
- Attributes
- protected
- Definition Classes
- MessageDispatcher → BatchingExecutor
- def unregister(actor: ActorCell): Unit
If you override it, you must call it.
If you override it, you must call it. But only ever once. See "detach" for the only invocation
INTERNAL API
- Attributes
- protected[pekko]
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)
- def formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from MessageDispatcher toStringFormat[MessageDispatcher] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @deprecated @inline()
- Deprecated
(Since version 2.12.16) Use
formatString.format(value)
instead ofvalue.formatted(formatString)
, or use thef""
string interpolator. In Java 15 and later,formatted
resolves to the new method in String which has reversed parameters.
- def prepare(): ExecutionContext
- Definition Classes
- ExecutionContext
- Annotations
- @deprecated
- Deprecated
(Since version 2.12.0) preparation of ExecutionContexts will be removed
- def →[B](y: B): (MessageDispatcher, B)
- Implicit
- This member is added by an implicit conversion from MessageDispatcher toArrowAssoc[MessageDispatcher] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @deprecated
- Deprecated
(Since version 2.13.0) Use
->
instead. If you still wish to display it as one character, consider using a font with programming ligatures such as Fira Code.