akka.dispatch
Class MessageDispatcherConfigurator

java.lang.Object
  akka.dispatch.MessageDispatcherConfigurator

Direct Known Subclasses:

BalancingDispatcherConfigurator, CallingThreadDispatcherConfigurator, DispatcherConfigurator, PinnedDispatcherConfigurator

public abstract class MessageDispatcherConfigurator
extends java.lang.Object

Base class to be used for hooking in new dispatchers into Dispatchers.

Constructor Summary

MessageDispatcherConfigurator(com.typesafe.config.Config config, DispatcherPrerequisites prerequisites)

Method Summary

com.typesafe.config.Config	config()
ExecutorServiceConfigurator	configureExecutor()
abstract MessageDispatcher	dispatcher() Returns an instance of MessageDispatcher given the configuration.
MailboxType	mailboxType() Returns a factory for the Mailbox given the configuration.
DispatcherPrerequisites	prerequisites()

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageDispatcherConfigurator

public MessageDispatcherConfigurator(com.typesafe.config.Config config,
                                     DispatcherPrerequisites prerequisites)

Method Detail

config

public com.typesafe.config.Config config()

prerequisites

public DispatcherPrerequisites prerequisites()

dispatcher

public abstract MessageDispatcher dispatcher()

Returns an instance of MessageDispatcher given the configuration. Depending on the needs the implementation may return a new instance for each invocation or return the same instance every time.

mailboxType

public MailboxType mailboxType()

Returns a factory for the Mailbox given the configuration. Default implementation instantiate the MailboxType specified as FQCN in mailbox-type config property. If mailbox-type is unspecified (empty) then UnboundedMailbox is used when capacity is < 1, otherwise BoundedMailbox.

configureExecutor

public ExecutorServiceConfigurator configureExecutor()