Class UnboundedMessageQueue

An unbounded mailbox message queue.

Inheritance
Object
UnboundedMessageQueue
Implements
Inherited Members
Namespace: Akka.Dispatch.MessageQueues
Assembly: Akka.dll
Syntax
public class UnboundedMessageQueue : IMessageQueue, IUnboundedMessageQueueSemantics, ISemantics

Properties

| Improve this Doc View Source

Count

Interface to be implemented by all mailbox message queues

Declaration
public int Count { get; }
Property Value
Type Description
Int32
| Improve this Doc View Source

HasMessages

Interface to be implemented by all mailbox message queues

Declaration
public bool HasMessages { get; }
Property Value
Type Description
Boolean

Methods

| Improve this Doc View Source

CleanUp(IActorRef, IMessageQueue)

Interface to be implemented by all mailbox message queues

Declaration
public void CleanUp(IActorRef owner, IMessageQueue deadletters)
Parameters
Type Name Description
IActorRef owner

The owner of this message queue if available, "/deadletters" otherwise.
IMessageQueue deadletters

The dead letters message queue.
| Improve this Doc View Source

Enqueue(IActorRef, Envelope)

Interface to be implemented by all mailbox message queues

Declaration
public void Enqueue(IActorRef receiver, Envelope envelope)
Parameters
Type Name Description
IActorRef receiver

The receiver of the messages.

This field is only used in a couple of places, but it should not be removed.
Envelope envelope

The envelope to enqueue

| Improve this Doc View Source

TryDequeue(out Envelope)

Interface to be implemented by all mailbox message queues

Declaration
public bool TryDequeue(out Envelope envelope)
Parameters
Type Name Description
Envelope envelope

The envelope that was dequeued

Returns
Type Description
Boolean

true if there's a message in the queue. false otherwise.

Implements

Extension Methods