Package akka.dispatch

Class BalancingDispatcher

  • All Implemented Interfaces:
    BatchingExecutor, java.util.concurrent.Executor, scala.concurrent.ExecutionContext, scala.concurrent.ExecutionContextExecutor

    public class BalancingDispatcher
    extends Dispatcher
    Deprecated.
    Use BalancingPool instead of BalancingDispatcher. Since 2.3.
    INTERNAL API
    • Constructor Detail

      • BalancingDispatcher

        public BalancingDispatcher​(MessageDispatcherConfigurator _configurator,
                                   java.lang.String _id,
                                   int throughput,
                                   scala.concurrent.duration.Duration throughputDeadlineTime,
                                   MailboxType _mailboxType,
                                   ExecutorServiceFactoryProvider _executorServiceFactoryProvider,
                                   scala.concurrent.duration.FiniteDuration _shutdownTimeout,
                                   boolean attemptTeamWork)
        Deprecated.
    • Method Detail

      • createMailbox

        protected Mailbox createMailbox​(Cell actor,
                                        MailboxType mailboxType)
        Deprecated.
        Description copied from class: Dispatcher
        INTERNAL API
        Overrides:
        createMailbox in class Dispatcher
        Parameters:
        actor - (undocumented)
        mailboxType - (undocumented)
        Returns:
        (undocumented)
      • dispatch

        protected void dispatch​(ActorCell receiver,
                                Envelope invocation)
        Deprecated.
        Description copied from class: Dispatcher
        INTERNAL API
        Overrides:
        dispatch in class Dispatcher
        Parameters:
        receiver - (undocumented)
        invocation - (undocumented)
      • messageQueue

        public MessageQueue messageQueue()
        Deprecated.
        INTERNAL API
        Returns:
        (undocumented)
      • register

        protected void register​(ActorCell actor)
        Deprecated.
        Description copied from class: MessageDispatcher
        If you override it, you must call it. But only ever once. See "attach" for only invocation.

        INTERNAL API

        Overrides:
        register in class MessageDispatcher
        Parameters:
        actor - (undocumented)
      • team

        public java.util.concurrent.ConcurrentSkipListSet<ActorCell> team()
        Deprecated.
      • teamWork

        protected void teamWork()
        Deprecated.
      • unregister

        protected void unregister​(ActorCell actor)
        Deprecated.
        Description copied from class: MessageDispatcher
        If you override it, you must call it. But only ever once. See "detach" for the only invocation

        INTERNAL API

        Overrides:
        unregister in class MessageDispatcher
        Parameters:
        actor - (undocumented)