Package akka.dispatch

Class Dispatcher

  • All Implemented Interfaces:
    BatchingExecutor, java.util.concurrent.Executor, scala.concurrent.ExecutionContext, scala.concurrent.ExecutionContextExecutor
    Direct Known Subclasses:
    BalancingDispatcher, PinnedDispatcher

    public class Dispatcher
    extends MessageDispatcher
    At first glance this var does not seem to be updated anywhere, but in fact it is, via the esUpdater AtomicReferenceFieldUpdater below.
    • Constructor Detail

      • Dispatcher

        public Dispatcher​(MessageDispatcherConfigurator _configurator,
                          java.lang.String id,
                          int throughput,
                          scala.concurrent.duration.Duration throughputDeadlineTime,
                          ExecutorServiceFactoryProvider executorServiceFactoryProvider,
                          scala.concurrent.duration.FiniteDuration shutdownTimeout)
    • Method Detail

      • dispatch

        protected void dispatch​(ActorCell receiver,
                                Envelope invocation)
        INTERNAL API
        Specified by:
        dispatch in class MessageDispatcher
        Parameters:
        receiver - (undocumented)
        invocation - (undocumented)
      • id

        public java.lang.String id()
        Description copied from class: MessageDispatcher
        Identifier of this dispatcher, corresponds to the full key of the dispatcher configuration.
        Specified by:
        id in class MessageDispatcher
        Returns:
        (undocumented)
      • registerForExecution

        protected boolean registerForExecution​(Mailbox mbox,
                                               boolean hasMessageHint,
                                               boolean hasSystemMessageHint)
        Returns if it was registered

        INTERNAL API

        Specified by:
        registerForExecution in class MessageDispatcher
        Parameters:
        mbox - (undocumented)
        hasMessageHint - (undocumented)
        hasSystemMessageHint - (undocumented)
        Returns:
        (undocumented)
      • shutdownTimeout

        public scala.concurrent.duration.FiniteDuration shutdownTimeout()
        Description copied from class: MessageDispatcher
        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

        INTERNAL API

        Specified by:
        shutdownTimeout in class MessageDispatcher
        Returns:
        (undocumented)
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object