Package akka.dispatch

Class NonBlockingBoundedMailbox

java.lang.Object

akka.dispatch.NonBlockingBoundedMailbox

All Implemented Interfaces:

MailboxType, ProducesMessageQueue<BoundedNodeMessageQueue>, java.io.Serializable, scala.Equals, scala.Product

public class NonBlockingBoundedMailbox
extends java.lang.Object
implements MailboxType, ProducesMessageQueue<BoundedNodeMessageQueue>, scala.Product, java.io.Serializable

NonBlockingBoundedMailbox is a high-performance, multiple-producer single-consumer, bounded MailboxType, Noteworthy is that it discards overflow as DeadLetters.

It can't have multiple consumers, which rules out using it with BalancingPool (BalancingDispatcher) for instance.

NOTE: NonBlockingBoundedMailbox does not use mailbox-push-timeout-time as it is non-blocking.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
NonBlockingBoundedMailbox(int capacity)
NonBlockingBoundedMailbox(ActorSystem.Settings settings, com.typesafe.config.Config config)

Method Summary

Modifier and Type	Method	Description
static NonBlockingBoundedMailbox	apply(int capacity)
boolean	canEqual(java.lang.Object x$1)
int	capacity()
NonBlockingBoundedMailbox	copy(int capacity)
int	copy$default$1()
MessageQueue	create(scala.Option<ActorRef> owner, scala.Option<ActorSystem> system)
boolean	equals(java.lang.Object x$1)
int	hashCode()
int	productArity()
java.lang.Object	productElement(int x$1)
java.lang.String	productElementName(int x$1)
scala.collection.Iterator<java.lang.Object>	productIterator()
java.lang.String	productPrefix()
java.lang.String	toString()
static scala.Option<java.lang.Object>	unapply(NonBlockingBoundedMailbox x$0)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface scala.Product

productElementNames

Constructor Detail

NonBlockingBoundedMailbox

public NonBlockingBoundedMailbox(int capacity)

NonBlockingBoundedMailbox

public NonBlockingBoundedMailbox(ActorSystem.Settings settings,
                                 com.typesafe.config.Config config)

Method Detail

apply

public static NonBlockingBoundedMailbox apply(int capacity)

unapply

public static scala.Option<java.lang.Object> unapply(NonBlockingBoundedMailbox x$0)

capacity

public int capacity()

create

public final MessageQueue create(scala.Option<ActorRef> owner,
                                 scala.Option<ActorSystem> system)

Specified by:

create in interface MailboxType

copy

public NonBlockingBoundedMailbox copy(int capacity)

copy$default$1

public int copy$default$1()

productPrefix

public java.lang.String productPrefix()

Specified by:

productPrefix in interface scala.Product

productArity

public int productArity()

Specified by:

productArity in interface scala.Product

productElement

public java.lang.Object productElement(int x$1)

Specified by:

productElement in interface scala.Product

productIterator

public scala.collection.Iterator<java.lang.Object> productIterator()

Specified by:

productIterator in interface scala.Product

canEqual

public boolean canEqual(java.lang.Object x$1)

Specified by:

canEqual in interface scala.Equals

productElementName

public java.lang.String productElementName(int x$1)

Specified by:

productElementName in interface scala.Product

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object x$1)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class java.lang.Object