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

| Edit this page View Source

BlockTimeOut

TBD

Declaration

public TimeSpan BlockTimeOut { get; set; }

Property Value

Type	Description
TimeSpan

| Edit this page View Source

Count

TBD

Declaration

public int Count { get; }

Property Value

Type	Description
int

| Edit this page View Source

HasMessages

TBD

Declaration

public bool HasMessages { get; }

Property Value

Type	Description
bool

| Edit this page View Source

LockedCount

TBD

Declaration

protected abstract int LockedCount { get; }

Property Value

Type	Description
int

Methods

| Edit this page View Source

CleanUp(IActorRef, IMessageQueue)

TBD

Declaration

public void CleanUp(IActorRef owner, IMessageQueue deadletters)

Parameters

Type	Name	Description
IActorRef	owner	TBD
IMessageQueue	deadletters	TBD

| Edit this page View Source

Enqueue(IActorRef, Envelope)

TBD

Declaration

public void Enqueue(IActorRef receiver, Envelope envelope)

Parameters

Type	Name	Description
IActorRef	receiver	TBD
Envelope	envelope	TBD

| Edit this page View Source

LockedEnqueue(Envelope)

TBD

Declaration

protected abstract void LockedEnqueue(Envelope envelope)

Parameters

Type	Name	Description
Envelope	envelope	TBD

| Edit this page View Source

LockedTryDequeue(out Envelope)

TBD

Declaration

protected abstract bool LockedTryDequeue(out Envelope envelope)

Parameters

Type	Name	Description
Envelope	envelope	TBD

Returns

Type	Description
bool	TBD

| Edit this page View Source

TryDequeue(out Envelope)

TBD

Declaration

public bool TryDequeue(out Envelope envelope)

Parameters

Type	Name	Description
Envelope	envelope	TBD

Returns

Type	Description
bool	TBD

Implements

IMessageQueue

IBlockingMessageQueueSemantics

IMultipleConsumerSemantics

ISemantics

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)