Package akka.dispatch

Class BalancingDispatcher

java.lang.Object

akka.dispatch.MessageDispatcher

akka.dispatch.Dispatcher

akka.dispatch.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

Nested Class Summary

Nested classes/interfaces inherited from interface scala.concurrent.ExecutionContext

scala.concurrent.ExecutionContext.Implicits$

Constructor Summary

Constructors

Constructor	Description
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 Summary

Modifier and Type	Method	Description
protected Mailbox	createMailbox(Cell actor, MailboxType mailboxType)	Deprecated. INTERNAL API
protected void	dispatch(ActorCell receiver, Envelope invocation)	Deprecated. INTERNAL API
MessageQueue	messageQueue()	Deprecated. INTERNAL API
protected void	register(ActorCell actor)	Deprecated. If you override it, you must call it.
java.util.concurrent.ConcurrentSkipListSet<ActorCell>	team()	Deprecated.
protected void	teamWork()	Deprecated.
protected void	unregister(ActorCell actor)	Deprecated. If you override it, you must call it.

Methods inherited from class akka.dispatch.Dispatcher

executeTask, executorService, id, registerForExecution, shutdown, shutdownTimeout, systemDispatch, throughput, throughputDeadlineTime, toString

Methods inherited from class akka.dispatch.MessageDispatcher

actors, attach, configurator, debug, detach, eventStream, inhabitants, isThroughputDeadlineTimeDefined, mailboxes, printActors, reportFailure, RESCHEDULED, resubmitOnBlock, resume, SCHEDULED, suspend, unbatchedExecute, UNSCHEDULED

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface akka.dispatch.BatchingExecutor

batchable, execute

Methods inherited from interface scala.concurrent.ExecutionContext

execute, prepare

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)