akka.testkit

CallingThreadMailbox

class CallingThreadMailbox extends Mailbox with DefaultSystemMessageQueue

Linear Supertypes
DefaultSystemMessageQueue, Mailbox, Runnable, SystemMessageQueue, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. CallingThreadMailbox
  2. DefaultSystemMessageQueue
  3. Mailbox
  4. Runnable
  5. SystemMessageQueue
  6. AnyRef
  7. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new CallingThreadMailbox (_receiver: ActorCell, mailboxType: MailboxType)

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. var _statusDoNotCallMeDirectly : Status

    Attributes
    protected
    Definition Classes
    Mailbox
  7. var _systemQueueDoNotCallMeDirectly : SystemMessage

    Attributes
    protected
    Definition Classes
    Mailbox
  8. val actor : ActorCell

    Definition Classes
    Mailbox
  9. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  10. def becomeClosed (): Boolean

    set new primary status Closed.

    set new primary status Closed. Caller does not need to worry about whether status was Scheduled or not.

    Attributes
    final
    Definition Classes
    Mailbox
    Annotations
    @tailrec()
  11. def becomeOpen (): Boolean

    set new primary status Open.

    set new primary status Open. Caller does not need to worry about whether status was Scheduled or not.

    Attributes
    final
    Definition Classes
    Mailbox
    Annotations
    @tailrec()
  12. def becomeSuspended (): Boolean

    set new primary status Suspended.

    set new primary status Suspended. Caller does not need to worry about whether status was Scheduled or not.

    Attributes
    final
    Definition Classes
    Mailbox
    Annotations
    @tailrec()
  13. def canBeScheduledForExecution (hasMessageHint: Boolean, hasSystemMessageHint: Boolean): Boolean

    Attributes
    final
    Definition Classes
    Mailbox
  14. def cleanUp (): Unit

    Overridable callback to clean up the mailbox, called when an actor is unregistered.

    Overridable callback to clean up the mailbox, called when an actor is unregistered. By default it dequeues all system messages + messages and ships them to the owning actors' systems' DeadLetterMailbox

    Definition Classes
    CallingThreadMailbox → Mailbox
  15. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  16. val ctdLock : ReentrantLock

  17. def dequeue (): Envelope

    Definition Classes
    Mailbox
  18. def dispatcher : MessageDispatcher

    Attributes
    final
    Definition Classes
    Mailbox
    Annotations
    @inline()
  19. def enqueue (receiver: ActorRef, msg: Envelope): Unit

    Definition Classes
    Mailbox
  20. def eq (arg0: AnyRef): Boolean

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

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

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

    Attributes
    final
    Definition Classes
    AnyRef → Any
  24. def hasMessages : Boolean

    Definition Classes
    Mailbox
  25. def hasSystemMessages : Boolean

    Definition Classes
    DefaultSystemMessageQueue
  26. def hashCode (): Int

    Definition Classes
    AnyRef → Any
  27. def isClosed : Boolean

    Attributes
    final
    Definition Classes
    Mailbox
    Annotations
    @inline()
  28. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  29. def isScheduled : Boolean

    Attributes
    final
    Definition Classes
    Mailbox
    Annotations
    @inline()
  30. def isSuspended : Boolean

    Attributes
    final
    Definition Classes
    Mailbox
    Annotations
    @inline()
  31. val mailboxType : MailboxType

  32. val messageQueue : MessageQueue

    Definition Classes
    Mailbox
  33. def ne (arg0: AnyRef): Boolean

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

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

    Attributes
    final
    Definition Classes
    AnyRef
  36. def numberOfMessages : Int

    Definition Classes
    Mailbox
  37. def processAllSystemMessages (): Unit

    Attributes
    final
    Definition Classes
    Mailbox
  38. def queue : NestingQueue

  39. def run (): Unit

    Attributes
    final
    Definition Classes
    Mailbox → Runnable
  40. def setAsIdle (): Boolean

    Reset Scheduled status, keeping primary status as is.

    Reset Scheduled status, keeping primary status as is.

    Attributes
    final
    Definition Classes
    Mailbox
    Annotations
    @tailrec()
  41. def setAsScheduled (): Boolean

    Set Scheduled status, keeping primary status as is.

    Set Scheduled status, keeping primary status as is.

    Attributes
    final
    Definition Classes
    Mailbox
    Annotations
    @tailrec()
  42. def setStatus (newStatus: Status): Unit

    Attributes
    protected final
    Definition Classes
    Mailbox
    Annotations
    @inline()
  43. def shouldProcessMessage : Boolean

    Attributes
    final
    Definition Classes
    Mailbox
    Annotations
    @inline()
  44. def status : Status

    Attributes
    final
    Definition Classes
    Mailbox
    Annotations
    @inline()
  45. val suspendSwitch : Switch

  46. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  47. def systemDrain (): SystemMessage

    Attributes
    final
    Definition Classes
    DefaultSystemMessageQueue
    Annotations
    @tailrec()
  48. def systemEnqueue (receiver: ActorRef, message: SystemMessage): Unit

    Attributes
    final
    Definition Classes
    DefaultSystemMessageQueue
    Annotations
    @tailrec()
  49. def systemQueueGet : SystemMessage

    Attributes
    protected final
    Definition Classes
    Mailbox
  50. def systemQueuePut (_old: SystemMessage, _new: SystemMessage): Boolean

    Attributes
    protected final
    Definition Classes
    Mailbox
  51. def toString (): String

    Definition Classes
    AnyRef → Any
  52. def updateStatus (oldStatus: Status, newStatus: Status): Boolean

    Attributes
    protected final
    Definition Classes
    Mailbox
    Annotations
    @inline()
  53. def wait (): Unit

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

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

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from DefaultSystemMessageQueue

Inherited from Mailbox

Inherited from Runnable

Inherited from SystemMessageQueue

Inherited from AnyRef

Inherited from Any