Package akka.dispatch

Class BoundedControlAwareMailbox.MessageQueue

    • Constructor Summary

      Constructor Description
      MessageQueue​(int capacity, scala.concurrent.duration.FiniteDuration pushTimeOut)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      int capacity()  
      java.util.concurrent.ConcurrentLinkedQueue<Envelope> controlQueue()  
      Envelope dequeue()
      Try to dequeue the next message from this queue, return null failing that.
      void enqueue​(ActorRef receiver, Envelope handle)
      Try to enqueue the message to this queue, or throw an exception.
      boolean hasMessages()
      Indicates whether this queue is non-empty.
      int numberOfMessages()
      Should return the current number of messages held in this queue; may always return 0 if no other value is available efficiently.
      scala.concurrent.duration.FiniteDuration pushTimeOut()  
      java.util.concurrent.ConcurrentLinkedQueue<Envelope> queue()  
      • Methods inherited from class java.lang.Object

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