Search Results for

    Show / Hide Table of Contents

    Class BoundedDequeMessageQueue

    A bounded double-ended queue. Used in combination with IStash.

    Inheritance
    object
    DequeWrapperMessageQueue
    BoundedDequeMessageQueue
    Implements
    IMessageQueue
    IBoundedDequeBasedMessageQueueSemantics
    IDequeBasedMessageQueueSemantics
    IBoundedMessageQueueSemantics
    ISemantics
    Inherited Members
    DequeWrapperMessageQueue.MessageQueue
    DequeWrapperMessageQueue.HasMessages
    DequeWrapperMessageQueue.Count
    DequeWrapperMessageQueue.Enqueue(IActorRef, Envelope)
    DequeWrapperMessageQueue.TryDequeue(out Envelope)
    DequeWrapperMessageQueue.CleanUp(IActorRef, IMessageQueue)
    DequeWrapperMessageQueue.EnqueueFirst(Envelope)
    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 BoundedDequeMessageQueue : DequeWrapperMessageQueue, IMessageQueue, IBoundedDequeBasedMessageQueueSemantics, IDequeBasedMessageQueueSemantics, IBoundedMessageQueueSemantics, ISemantics

    Constructors

    | Edit this page View Source

    BoundedDequeMessageQueue(int, TimeSpan)

    TBD

    Declaration
    public BoundedDequeMessageQueue(int boundedCapacity, TimeSpan pushTimeOut)
    Parameters
    Type Name Description
    int boundedCapacity

    TBD

    TimeSpan pushTimeOut

    TBD

    Properties

    | Edit this page View Source

    PushTimeOut

    Gets the underlying PushTimeOut

    Declaration
    public TimeSpan PushTimeOut { get; }
    Property Value
    Type Description
    TimeSpan
    Remarks

    This method is never called, but had to be implemented to support the IBoundedDequeBasedMessageQueueSemantics interface.

    Implements

    IMessageQueue
    IBoundedDequeBasedMessageQueueSemantics
    IDequeBasedMessageQueueSemantics
    IBoundedMessageQueueSemantics
    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