Class PinnedDispatcher

Dedicates a unique thread for each actor passed in as reference. Served through its IMessageQueue.

The preferred way of creating dispatcher is to define them in configuration and then use the Lookup(string) method.

Inheritance

object

MessageDispatcher

Dispatcher

PinnedDispatcher

Inherited Members

MessageDispatcher.DefaultThroughput

MessageDispatcher.Configurator

MessageDispatcher.EventStream

MessageDispatcher.Mailboxes

MessageDispatcher.Id

MessageDispatcher.ThroughputDeadlineTime

MessageDispatcher.Throughput

MessageDispatcher.Schedule(Action)

MessageDispatcher.Schedule(IRunnable)

MessageDispatcher.Dispatch(ActorCell, Envelope)

MessageDispatcher.SystemDispatch(ActorCell, SystemMessage)

MessageDispatcher.Attach(ActorCell)

MessageDispatcher.Detach(ActorCell)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Akka.Dispatch

Assembly: Akka.dll

Syntax

public sealed class PinnedDispatcher : Dispatcher

Constructors

PinnedDispatcher(MessageDispatcherConfigurator, string, int, long?, ExecutorServiceFactory, TimeSpan)

TBD

Declaration

public PinnedDispatcher(MessageDispatcherConfigurator configurator, string id, int throughput, long? throughputDeadlineTime, ExecutorServiceFactory executorServiceFactory, TimeSpan shutdownTimeout)

Parameters

Type	Name	Description
MessageDispatcherConfigurator	configurator	TBD
string	id	TBD
int	throughput	TBD
long?	throughputDeadlineTime	TBD
ExecutorServiceFactory	executorServiceFactory	TBD
TimeSpan	shutdownTimeout	TBD

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)