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

Methods

Create<T>(string, IActorRef, Option<Props>, 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