c

akka.dispatch

NonBlockingBoundedMailbox

case class NonBlockingBoundedMailbox(capacity: Int) extends MailboxType with ProducesMessageQueue[BoundedNodeMessageQueue] with Product with 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.

Source
Mailbox.scala
Linear Supertypes
Serializable, Product, Equals, ProducesMessageQueue[BoundedNodeMessageQueue], MailboxType, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. NonBlockingBoundedMailbox
  2. Serializable
  3. Product
  4. Equals
  5. ProducesMessageQueue
  6. MailboxType
  7. AnyRef
  8. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new NonBlockingBoundedMailbox(settings: Settings, config: Config)
  2. new NonBlockingBoundedMailbox(capacity: Int)

Value Members

  1. val capacity: Int
  2. final def create(owner: [ActorRef], system: [ActorSystem]): MessageQueue
    Definition Classes
    → MailboxType
  3. def productElementNames: Iterator[String]
    Definition Classes
    Product