Search Results for

    Show / Hide Table of Contents

    Class UnboundedMessageQueue

    An unbounded mailbox message queue.

    Inheritance
    object
    UnboundedMessageQueue
    Implements
    IMessageQueue
    IUnboundedMessageQueueSemantics
    ISemantics
    Inherited Members
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.MemberwiseClone()
    object.ReferenceEquals(object, object)
    object.ToString()
    Namespace: Akka.Dispatch.MessageQueues
    Assembly: Akka.dll
    Syntax
    public class UnboundedMessageQueue : IMessageQueue, IUnboundedMessageQueueSemantics, ISemantics

    Properties

    | Edit this page View Source

    Count

    Interface to be implemented by all mailbox message queues

    Declaration
    public int Count { get; }
    Property Value
    Type Description
    int
    | Edit this page View Source

    HasMessages

    Interface to be implemented by all mailbox message queues

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

    Methods

    | Edit this page 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
    IMessageQueue deadletters
    | Edit this page 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
    Envelope envelope
    | Edit this page 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
    Returns
    Type Description
    bool

    Implements

    IMessageQueue
    IUnboundedMessageQueueSemantics
    ISemantics

    Extension Methods

    ObjectExtensions.IsDefaultForType<T>(T)
    ObjectExtensions.AsOption<T>(T)
    Extensions.AsInstanceOf<T>(object)
    In this article
    • githubEdit this page
    • View Source
    Back to top
    Contribute
    • Project Chat
    • Discussion Forum
    • Source Code
    Support
    • Akka.NET Support Plans
    • Akka.NET Observability Tools
    • Akka.NET Training & Consulting
    Maintained By
    • Petabridge - The Akka.NET Company
    • Learn Akka.NET