Packages

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, Serializable, Product, Equals, ProducesMessageQueue[BoundedNodeMessageQueue], MailboxType, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. NonBlockingBoundedMailbox
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. ProducesMessageQueue
  7. MailboxType
  8. AnyRef
  9. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

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: Option[ActorRef], system: Option[ActorSystem]): MessageQueue
    Definition Classes
    NonBlockingBoundedMailbox → MailboxType