Class UnboundedDequeMessageQueue

An unbounded double-ended queue. Used in combination with IStash.

Inheritance

Object

DequeWrapperMessageQueue

UnboundedDequeMessageQueue

Implements

IMessageQueue

IUnboundedDequeBasedMessageQueueSemantics

IDequeBasedMessageQueueSemantics

IUnboundedMessageQueueSemantics

ISemantics

Inherited Members

DequeWrapperMessageQueue.MessageQueue

DequeWrapperMessageQueue.HasMessages

DequeWrapperMessageQueue.Count

DequeWrapperMessageQueue.Enqueue(IActorRef, Envelope)

DequeWrapperMessageQueue.TryDequeue(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 UnboundedDequeMessageQueue : DequeWrapperMessageQueue, IMessageQueue, IUnboundedDequeBasedMessageQueueSemantics, IDequeBasedMessageQueueSemantics, IUnboundedMessageQueueSemantics, ISemantics

Constructors

UnboundedDequeMessageQueue()

TBD

Declaration

public UnboundedDequeMessageQueue()

Implements

IMessageQueue

IUnboundedDequeBasedMessageQueueSemantics

IDequeBasedMessageQueueSemantics

IUnboundedMessageQueueSemantics

ISemantics

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)