Class TailChopping

This class contains logic used by a Router to route a message to a Routee determined using tail-chopping. This process has the router select a random routee, then waits an interval before sending to a different randomly chosen routee. The first response is used and the remaining are discarded. If the none of the routees respond within a specified time limit, a timeout failure occurs.

Inheritance

object

RoutingLogic

TailChopping

Implements

INoSerializationVerificationNeeded

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Akka.Routing

Assembly: Akka.dll

Syntax

public sealed class TailChopping : RoutingLogic, INoSerializationVerificationNeeded

Constructors

TailChopping(IScheduler, TimeSpan, TimeSpan)

Initializes a new instance of the TailChopping class.

Declaration

public TailChopping(IScheduler scheduler, TimeSpan within, TimeSpan interval)

Parameters

Type	Name	Description
IScheduler	scheduler	The IScheduler used to force deadlines.
TimeSpan	within	The time within which at least one response is expected.
TimeSpan	interval	The duration after which the next routee will be picked.

Methods

Select(object, Routee[])

Picks all of the provided routees to receive the message.

Declaration

public override Routee Select(object message, Routee[] routees)

Parameters

Type	Name	Description
object	message	The message that is being routed
Routee[]	routees	A collection of routees used when receiving the message.

Returns

Type	Description
Routee	A Akka.Routing.TailChoppingRoutee that receives the message.

Overrides

RoutingLogic.Select(object, Routee[])

Implements

INoSerializationVerificationNeeded

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)