akka.dispatch

DefaultBoundedMessageQueue

class DefaultBoundedMessageQueue extends LinkedBlockingQueue[MessageInvocation] with BoundedMessageQueueSemantics

Linear Supertypes
BoundedMessageQueueSemantics, MessageQueue, LinkedBlockingQueue[MessageInvocation], Serializable, BlockingQueue[MessageInvocation], AbstractQueue[MessageInvocation], Queue[MessageInvocation], AbstractCollection[MessageInvocation], Collection[MessageInvocation], Iterable[MessageInvocation], AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. DefaultBoundedMessageQueue
  2. BoundedMessageQueueSemantics
  3. MessageQueue
  4. LinkedBlockingQueue
  5. Serializable
  6. BlockingQueue
  7. AbstractQueue
  8. Queue
  9. AbstractCollection
  10. Collection
  11. Iterable
  12. AnyRef
  13. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new DefaultBoundedMessageQueue (capacity: Int, pushTimeOut: Duration)

Value Members

  1. def != (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any
  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  6. def add (arg0: MessageInvocation): Boolean

    Definition Classes
    AbstractQueue → Queue → AbstractCollection → Collection
  7. def addAll (arg0: java.util.Collection[_ <: akka.dispatch.MessageInvocation]): Boolean

    Definition Classes
    AbstractQueue → AbstractCollection → Collection
  8. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  9. def clear (): Unit

    Definition Classes
    LinkedBlockingQueue → AbstractQueue → AbstractCollection → Collection
  10. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  11. def contains (arg0: Any): Boolean

    Definition Classes
    AbstractCollection → Collection
  12. def containsAll (arg0: java.util.Collection[_]): Boolean

    Definition Classes
    AbstractCollection → Collection
  13. def dequeue (): MessageInvocation

    Attributes
    final
    Definition Classes
    BoundedMessageQueueSemanticsMessageQueue
    Annotations
    @inline()
  14. val dispatcherLock : SimpleLock

    Definition Classes
    MessageQueue
  15. def drainTo (arg0: java.util.Collection[_ >: akka.dispatch.MessageInvocation], arg1: Int): Int

    Definition Classes
    LinkedBlockingQueue → BlockingQueue
  16. def drainTo (arg0: java.util.Collection[_ >: akka.dispatch.MessageInvocation]): Int

    Definition Classes
    LinkedBlockingQueue → BlockingQueue
  17. def element (): MessageInvocation

    Definition Classes
    AbstractQueue → Queue
  18. def enqueue (handle: MessageInvocation): Unit

    Attributes
    final
    Definition Classes
    BoundedMessageQueueSemanticsMessageQueue
  19. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  20. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  21. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  22. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any
  23. def hashCode (): Int

    Definition Classes
    AnyRef → Any
  24. def isEmpty (): Boolean

    Definition Classes
    AbstractCollection → Collection
  25. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  26. def iterator (): Iterator[MessageInvocation]

    Definition Classes
    LinkedBlockingQueue → AbstractCollection → Collection → Iterable
  27. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  28. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  29. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  30. def offer (arg0: MessageInvocation): Boolean

    Definition Classes
    LinkedBlockingQueue → BlockingQueue → Queue
  31. def offer (arg0: MessageInvocation, arg1: Long, arg2: TimeUnit): Boolean

    Definition Classes
    LinkedBlockingQueue → BlockingQueue
    Annotations
    @throws()
  32. def peek (): MessageInvocation

    Definition Classes
    LinkedBlockingQueue → Queue
  33. def poll (): MessageInvocation

    Definition Classes
    LinkedBlockingQueue → Queue
  34. def poll (arg0: Long, arg1: TimeUnit): MessageInvocation

    Definition Classes
    LinkedBlockingQueue → BlockingQueue
    Annotations
    @throws()
  35. val pushTimeOut : Duration

  36. def put (arg0: MessageInvocation): Unit

    Definition Classes
    LinkedBlockingQueue → BlockingQueue
    Annotations
    @throws()
  37. def remainingCapacity (): Int

    Definition Classes
    LinkedBlockingQueue → BlockingQueue
  38. def remove (arg0: Any): Boolean

    Definition Classes
    LinkedBlockingQueue → BlockingQueue → AbstractCollection → Collection
  39. def remove (): MessageInvocation

    Definition Classes
    AbstractQueue → Queue
  40. def removeAll (arg0: java.util.Collection[_]): Boolean

    Definition Classes
    AbstractCollection → Collection
  41. def retainAll (arg0: java.util.Collection[_]): Boolean

    Definition Classes
    AbstractCollection → Collection
  42. def size (): Int

    Definition Classes
    LinkedBlockingQueue → AbstractCollection → Collection
  43. val suspended : SimpleLock

    Definition Classes
    MessageQueue
  44. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  45. def take (): MessageInvocation

    Definition Classes
    LinkedBlockingQueue → BlockingQueue
    Annotations
    @throws()
  46. def toArray [T] (arg0: Array[T]): Array[T]

    Definition Classes
    LinkedBlockingQueue → AbstractCollection → Collection
  47. def toArray (): Array[AnyRef]

    Definition Classes
    LinkedBlockingQueue → AbstractCollection → Collection
  48. def toString (): String

    Definition Classes
    LinkedBlockingQueue → AbstractCollection → AnyRef → Any
  49. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  50. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  51. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from BoundedMessageQueueSemantics

Inherited from MessageQueue

Inherited from LinkedBlockingQueue[MessageInvocation]

Inherited from Serializable

Inherited from BlockingQueue[MessageInvocation]

Inherited from AbstractQueue[MessageInvocation]

Inherited from Queue[MessageInvocation]

Inherited from AbstractCollection[MessageInvocation]

Inherited from Collection[MessageInvocation]

Inherited from Iterable[MessageInvocation]

Inherited from AnyRef

Inherited from Any