akka.dispatch

Class Mailboxes

java.lang.Object

akka.dispatch.Mailboxes

public class Mailboxes
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Mailboxes(ActorSystem.Settings settings, EventStream eventStream, DynamicAccess dynamicAccess, ActorRef deadLetters)

Method Summary

Modifier and Type	Method and Description
Mailbox	deadLetterMailbox()
static java.lang.String	DefaultMailboxId()
EventStream	eventStream()
java.lang.Class<?>	getMailboxRequirement(com.typesafe.config.Config config)
protected MailboxType	getMailboxType(Props props, com.typesafe.config.Config dispatcherConfig) Finds out the mailbox type for an actor based on configuration, props and requirements.
java.lang.Class<?>	getProducedMessageQueueType(MailboxType mailboxType)
java.lang.Class<?>	getRequiredType(java.lang.Class<? extends Actor> actorClass) Return the required message queue type for this class if any.
boolean	hasRequiredType(java.lang.Class<? extends Actor> actorClass) Check if this class can have a required message queue type.
MailboxType	lookup(java.lang.String id) Returns a mailbox type as specified in configuration, based on the id, or if not defined None.
MailboxType	lookupByQueueType(java.lang.Class<?> queueType) Returns a mailbox type as specified in configuration, based on the type, or if not defined None.
static java.lang.String	NoMailboxRequirement()
ActorSystem.Settings	settings()
int	stashCapacity(java.lang.String dispatcher, java.lang.String mailbox) INTERNAL API: The capacity of the stash.

Methods inherited from class java.lang.Object

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

Constructor Detail

Mailboxes

public Mailboxes(ActorSystem.Settings settings,
                 EventStream eventStream,
                 DynamicAccess dynamicAccess,
                 ActorRef deadLetters)

Method Detail

DefaultMailboxId

public static final java.lang.String DefaultMailboxId()

NoMailboxRequirement

public static final java.lang.String NoMailboxRequirement()

settings

public ActorSystem.Settings settings()

eventStream

public EventStream eventStream()

deadLetterMailbox

public Mailbox deadLetterMailbox()

lookup

public MailboxType lookup(java.lang.String id)

Returns a mailbox type as specified in configuration, based on the id, or if not defined None.

Parameters:

id - (undocumented)

Returns:

(undocumented)

lookupByQueueType

public MailboxType lookupByQueueType(java.lang.Class<?> queueType)

Returns a mailbox type as specified in configuration, based on the type, or if not defined None.

Parameters:

queueType - (undocumented)

Returns:

(undocumented)

getRequiredType

public java.lang.Class<?> getRequiredType(java.lang.Class<? extends Actor> actorClass)

Return the required message queue type for this class if any.

Parameters:

actorClass - (undocumented)

Returns:

(undocumented)

getMailboxRequirement

public java.lang.Class<?> getMailboxRequirement(com.typesafe.config.Config config)

getProducedMessageQueueType

public java.lang.Class<?> getProducedMessageQueueType(MailboxType mailboxType)

getMailboxType

protected MailboxType getMailboxType(Props props,
                                     com.typesafe.config.Config dispatcherConfig)

Finds out the mailbox type for an actor based on configuration, props and requirements.

Parameters:

props - (undocumented)

dispatcherConfig - (undocumented)

Returns:

(undocumented)

hasRequiredType

public boolean hasRequiredType(java.lang.Class<? extends Actor> actorClass)

Check if this class can have a required message queue type.

Parameters:

actorClass - (undocumented)

Returns:

(undocumented)

stashCapacity

public final int stashCapacity(java.lang.String dispatcher,
                               java.lang.String mailbox)

INTERNAL API: The capacity of the stash. Configured in the actor's mailbox or dispatcher config.

Parameters:

dispatcher - (undocumented)

mailbox - (undocumented)

Returns:

(undocumented)