Class ShardingProducerController

Reliable delivery between a producer actor sending messages to sharded consumer actors receiving the messages.

The ShardingProducerController should be used together with ShardingConsumerController.

A producer can send messages via a ShardingProducerController to any ShardingConsumerController identified by a unique String. A single ShardingProducerController per ActorSystem (node) can be shared for sending to all entities of a certain entity type. No explicit registration is needed between the ShardingConsumerController and the ShardingProducerController.

The producer actor will start the flow by sending an initial ShardingProducerController.Start<T> messages to the ShardingProducerController.

Inheritance

Object

ShardingProducerController

Inherited Members

Object.Equals(Object)

Object.Equals(Object, Object)

Object.GetHashCode()

Object.GetType()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Object.ToString()

Namespace: Akka.Cluster.Sharding.Delivery

Assembly: Akka.Cluster.Sharding.dll

Syntax

public static class ShardingProducerController

Fields

Empty

Declaration

public static readonly ShardingProducerController.State<T> Empty

Field Value

Type	Description
Akka.Cluster.Sharding.Delivery.ShardingProducerController.State<T>

Properties

BufferSize

Declaration

public long BufferSize { get; }

Property Value

Type	Description
Int64

Methods

Create<T>(String, IActorRef, Option<Props>, ShardingProducerController.Settings)

Declaration

public static Props Create<T>(string producerId, IActorRef shardRegion, Option<Props> durableQueue, ShardingProducerController.Settings settings)

Parameters

Type	Name	Description
String	producerId
IActorRef	shardRegion
Option<Props>	durableQueue
ShardingProducerController.Settings	settings

Returns

Type	Description
Props

Type Parameters

Name	Description
T