Class TailChoppingPool

This class represents a Pool router that sends messages 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

RouterConfig

Pool

TailChoppingPool

Implements

ISurrogated

IEquatable<RouterConfig>

IEquatable<Pool>

Inherited Members

Pool.NrOfInstances

Pool.UsePoolDispatcher

Pool.Resizer

Pool.SupervisorStrategy

Pool.Props(Props)

Pool.StopRouterWhenAllRouteesRemoved

Pool.CreateRouterActor()

Pool.DefaultSupervisorStrategy

Pool.Equals(Pool)

Pool.Equals(Object)

Pool.GetHashCode()

RouterConfig.RouterDispatcher

RouterConfig.RoutingLogicController(RoutingLogic)

RouterConfig.IsManagementMessage(Object)

RouterConfig.VerifyConfig(ActorPath)

RouterConfig.Equals(RouterConfig)

Object.Equals(Object, Object)

Object.GetType()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Object.ToString()

Namespace: Akka.Routing

Assembly: Akka.dll

Syntax

public sealed class TailChoppingPool : Pool, ISurrogated, IEquatable<RouterConfig>, IEquatable<Pool>

Constructors

| Improve this Doc View Source

TailChoppingPool(Config)

Initializes a new instance of the TailChoppingPool class.

note

'nr-of-instances', 'within', and 'tail-chopping-router.interval' must be defined in the provided configuration.

Declaration

public TailChoppingPool(Config config)

Parameters

Type	Name	Description
Config	config	The configuration used to configure the pool.

| Improve this Doc View Source

TailChoppingPool(Int32, Resizer, SupervisorStrategy, String, TimeSpan, TimeSpan, Boolean)

Initializes a new instance of the TailChoppingPool class.

Declaration

public TailChoppingPool(int nrOfInstances, Resizer resizer, SupervisorStrategy supervisorStrategy, string routerDispatcher, TimeSpan within, TimeSpan interval, bool usePoolDispatcher = false)

Parameters

Type	Name	Description
Int32	nrOfInstances	The initial number of routees in the pool.
Resizer	resizer	The resizer to use when dynamically allocating routees to the pool.
SupervisorStrategy	supervisorStrategy	The strategy to use when supervising the pool.
String	routerDispatcher	The dispatcher to use when passing messages to the routees.
TimeSpan	within	The amount of time to wait for a response.
TimeSpan	interval	The interval to wait before sending to the next routee.
Boolean	usePoolDispatcher	`true` to use the pool dispatcher; otherwise `false`.

| Improve this Doc View Source

TailChoppingPool(Int32, TimeSpan, TimeSpan)

Initializes a new instance of the TailChoppingPool class.

Declaration

public TailChoppingPool(int nrOfInstances, TimeSpan within, TimeSpan interval)

Parameters

Type	Name	Description
Int32	nrOfInstances	The initial number of routees in the pool.
TimeSpan	within	The amount of time to wait for a response.
TimeSpan	interval	The interval to wait before sending to the next routee.

Properties

| Improve this Doc View Source

Interval

The amount of time to wait before sending to the next routee.

Declaration

public TimeSpan Interval { get; }

Property Value

Type	Description
TimeSpan

| Improve this Doc View Source

Within

The amount of time to wait for a response.

Declaration

public TimeSpan Within { get; }

Property Value

Type	Description
TimeSpan

Methods

| Improve this Doc View Source

CreateRouter(ActorSystem)

Creates a router that is responsible for routing messages to routees within the provided system.

Declaration

public override Router CreateRouter(ActorSystem system)

Parameters

Type	Name	Description
ActorSystem	system	The actor system that owns this router.

Returns

Type	Description
Router	The newly created router tied to the given system.

Overrides

RouterConfig.CreateRouter(ActorSystem)

| Improve this Doc View Source

GetNrOfInstances(ActorSystem)

Used by the Akka.Routing.RoutedActorCell to determine the initial number of routees.

Declaration

public override int GetNrOfInstances(ActorSystem system)

Parameters

Type	Name	Description
ActorSystem	system	The actor system that owns this router.

Returns

Type	Description
Int32	The number of routees associated with this pool.

Overrides

Pool.GetNrOfInstances(ActorSystem)

| Improve this Doc View Source

ToSurrogate(ActorSystem)

Creates a surrogate representation of the current TailChoppingPool.

Declaration

public override ISurrogate ToSurrogate(ActorSystem system)

Parameters

Type	Name	Description
ActorSystem	system	The actor system that owns this router.

Returns

Type	Description
ISurrogate	The surrogate representation of the current TailChoppingPool.

Overrides

RouterConfig.ToSurrogate(ActorSystem)

| Improve this Doc View Source

WithDispatcher(String)

Creates a new TailChoppingPool router with a given dispatcher id.

note

This method is immutable and returns a new instance of the router.

Declaration

public TailChoppingPool WithDispatcher(string dispatcher)

Parameters

Type	Name	Description
String	dispatcher	The dispatcher id used to configure the new router.

Returns

Type	Description
TailChoppingPool	A new router with the provided dispatcher id.

| Improve this Doc View Source

WithFallback(RouterConfig)

Configure the current router with an auxiliary router for routes that it does not know how to handle.

Declaration

public override RouterConfig WithFallback(RouterConfig routerConfig)

Parameters

Type	Name	Description
RouterConfig	routerConfig	The router to use as an auxiliary source.

Returns

Type	Description
RouterConfig	The router configured with the auxiliary information.

Overrides

RouterConfig.WithFallback(RouterConfig)

| Improve this Doc View Source

WithResizer(Resizer)

Creates a new TailChoppingPool router with a given Resizer.

note

This method is immutable and returns a new instance of the router.

Declaration

public TailChoppingPool WithResizer(Resizer resizer)

Parameters

Type	Name	Description
Resizer	resizer	The Resizer used to configure the new router.

Returns

Type	Description
TailChoppingPool	A new router with the provided `resizer`.

| Improve this Doc View Source

WithSupervisorStrategy(SupervisorStrategy)

Creates a new TailChoppingPool router with a given SupervisorStrategy.

note

This method is immutable and returns a new instance of the router.

Declaration

public TailChoppingPool WithSupervisorStrategy(SupervisorStrategy strategy)

Parameters

Type	Name	Description
SupervisorStrategy	strategy	The SupervisorStrategy used to configure the new router.

Returns

Type	Description
TailChoppingPool	A new router with the provided `strategy`.

Implements

ISurrogated

IEquatable<T>

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)