Search Results for

    Show / Hide Table of Contents

    Class BoundedDequeBasedMailbox

    BoundedDequeBasedMailbox is an bounded MailboxType backed by a double-ended queue. Used for stashing.

    Inheritance
    object
    MailboxType
    BoundedDequeBasedMailbox
    Implements
    IProducesMessageQueue<BoundedDequeMessageQueue>
    IProducesPushTimeoutSemanticsMailbox
    Inherited Members
    MailboxType.Settings
    MailboxType.Config
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.MemberwiseClone()
    object.ReferenceEquals(object, object)
    object.ToString()
    Namespace: Akka.Dispatch
    Assembly: Akka.dll
    Syntax
    public class BoundedDequeBasedMailbox : MailboxType, IProducesMessageQueue<BoundedDequeMessageQueue>, IProducesPushTimeoutSemanticsMailbox

    Constructors

    | Edit this page View Source

    BoundedDequeBasedMailbox(Settings, Config)

    A factory to create IMessageQueues for an optionally provided IActorContext.

    Declaration
    public BoundedDequeBasedMailbox(Settings settings, Config config)
    Parameters
    Type Name Description
    Settings settings
    Config config
    Remarks

    Possibly important notice.

    When implementing a custom MailboxType, be aware that there is special semantics attached to ActorOf(Props, string) in that sending the returned IActorRef may, for a short period of time, enqueue the messages first in a dummy queue. Top-level actors are created in two steps, and only after the guardian actor ahs performed that second step will all previously sent messages be transferred from the dummy queue to the real mailbox.

    Implemented as an abstract class in order to enforce constructor requirements.

    Exceptions
    Type Condition
    ArgumentException

    This exception is thrown if the 'mailbox-capacity' in config or the 'mailbox-push-timeout-time' in config is negative.

    Properties

    | Edit this page View Source

    Capacity

    The capacity of this mailbox.

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

    PushTimeout

    The push timeout. Fires a TimeoutException if it takes longer than this to add a message to a full bounded mailbox.

    Declaration
    public TimeSpan PushTimeout { get; }
    Property Value
    Type Description
    TimeSpan

    Methods

    | Edit this page View Source

    Create(IActorRef, ActorSystem)

    A factory to create IMessageQueues for an optionally provided IActorContext.

    Declaration
    public override IMessageQueue Create(IActorRef owner, ActorSystem system)
    Parameters
    Type Name Description
    IActorRef owner
    ActorSystem system
    Returns
    Type Description
    IMessageQueue
    Overrides
    MailboxType.Create(IActorRef, ActorSystem)
    Remarks

    Possibly important notice.

    When implementing a custom MailboxType, be aware that there is special semantics attached to ActorOf(Props, string) in that sending the returned IActorRef may, for a short period of time, enqueue the messages first in a dummy queue. Top-level actors are created in two steps, and only after the guardian actor ahs performed that second step will all previously sent messages be transferred from the dummy queue to the real mailbox.

    Implemented as an abstract class in order to enforce constructor requirements.

    Implements

    IProducesMessageQueue<TQueue>
    IProducesPushTimeoutSemanticsMailbox

    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