Class BlockingMessageQueue

Base class for blocking message queues. Allows non thread safe data structures to be used as message queues.

Inheritance

Object

BlockingMessageQueue

UnboundedPriorityMessageQueue

UnboundedStablePriorityMessageQueue

Implements

IMessageQueue

IBlockingMessageQueueSemantics

IMultipleConsumerSemantics

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 abstract class BlockingMessageQueue : IMessageQueue, IBlockingMessageQueueSemantics, IMultipleConsumerSemantics, ISemantics

Properties

| Improve this Doc View Source

BlockTimeOut

TBD

Declaration

public TimeSpan BlockTimeOut { get; set; }

Property Value

Type	Description
TimeSpan

| Improve this Doc View Source

Count

TBD

Declaration

public int Count { get; }

Property Value

Type	Description
Int32

| Improve this Doc View Source

HasMessages

TBD

Declaration

public bool HasMessages { get; }

Property Value

Type	Description
Boolean

| Improve this Doc View Source

LockedCount

TBD

Declaration

protected abstract int LockedCount { get; }

Property Value

Type	Description
Int32

Methods

| Improve this Doc View Source

CleanUp(IActorRef, IMessageQueue)

TBD

Declaration

public void CleanUp(IActorRef owner, IMessageQueue deadletters)

Parameters

Type	Name	Description
IActorRef	owner	TBD
IMessageQueue	deadletters	TBD

| Improve this Doc View Source

Enqueue(IActorRef, Envelope)

TBD

Declaration

public void Enqueue(IActorRef receiver, Envelope envelope)

Parameters

Type	Name	Description
IActorRef	receiver	TBD
Envelope	envelope	TBD

| Improve this Doc View Source

LockedEnqueue(Envelope)

TBD

Declaration

protected abstract void LockedEnqueue(Envelope envelope)

Parameters

Type	Name	Description
Envelope	envelope	TBD

| Improve this Doc View Source

LockedTryDequeue(out Envelope)

TBD

Declaration

protected abstract bool LockedTryDequeue(out Envelope envelope)

Parameters

Type	Name	Description
Envelope	envelope	TBD

Returns

Type	Description
Boolean	TBD

| Improve this Doc View Source

TryDequeue(out Envelope)

TBD

Declaration

public bool TryDequeue(out Envelope envelope)

Parameters

Type	Name	Description
Envelope	envelope	TBD

Returns

Type	Description
Boolean	TBD

Implements

IMessageQueue

IBlockingMessageQueueSemantics

IMultipleConsumerSemantics

ISemantics

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)