Package org.apache.pekko.cluster.sharding.typed.delivery

Class ShardingConsumerController$

java.lang.Object

org.apache.pekko.cluster.sharding.typed.delivery.ShardingConsumerController$

public class ShardingConsumerController$
extends Object

ShardingConsumerController is used together with ShardingProducerController. See the description in that class or the Pekko reference documentation for how they are intended to be used.

ShardingConsumerController is the entity that is initialized in ClusterSharding. It will manage the lifecycle and message delivery to the destination consumer actor.

The destination consumer actor will start the flow by sending an initial pekko.actor.typed.delivery.ConsumerController.Start message via the ActorRef provided in the factory function of the consumer Behavior. The ActorRef in the Start message is typically constructed as a message adapter to map the pekko.actor.typed.delivery.ConsumerController.Delivery to the protocol of the consumer actor.

Received messages from the producer are wrapped in pekko.actor.typed.delivery.ConsumerController.Delivery when sent to the consumer, which is supposed to reply with pekko.actor.typed.delivery.ConsumerController.Confirmed when it has processed the message. Next message from a specific producer is not delivered until the previous is confirmed. However, since there can be several producers, e.g. one per node, sending to the same destination entity there can be several Delivery in flight at the same time. More messages from a specific producer that arrive while waiting for the confirmation are stashed by the ConsumerController and delivered when previous message was confirmed.

Field Summary

Fields

Modifier and Type	Field	Description
static final ShardingConsumerController$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
ShardingConsumerController$()

Method Summary

Modifier and Type	Method	Description
<A, B> Behavior<ConsumerController.SequencedMessage<A>>	apply(scala.Function1<ActorRef<ConsumerController.Start<A>>,Behavior<B>> consumerBehavior)	The Behavior of the entity that is to be initialized in ClusterSharding.
<A, B> Behavior<ConsumerController.SequencedMessage<A>>	create(Function<ActorRef<ConsumerController.Start<A>>,Behavior<B>> consumerBehavior)	Java API: The Behavior of the entity that is to be initialized in ClusterSharding.
<A, B> Behavior<ConsumerController.SequencedMessage<A>>	create(Function<ActorRef<ConsumerController.Start<A>>,Behavior<B>> consumerBehavior, ShardingConsumerController.Settings settings)	Java API: The Behavior of the entity that is to be initialized in ClusterSharding.
<A> Class<ConsumerController.SequencedMessage<A>>	entityTypeKeyClass()	Java API: The generic Class type for ConsumerController.SequencedMessage that can be used when creating an EntityTypeKey for the ShardedConsumerController with Class<EntityTypeKey<ConsumerController.SequencedMessage>>.
<A, B> Behavior<ConsumerController.SequencedMessage<A>>	withSettings(ShardingConsumerController.Settings settings, scala.Function1<ActorRef<ConsumerController.Start<A>>,Behavior<B>> consumerBehavior)	The Behavior of the entity that is to be initialized in ClusterSharding.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MODULE$

public static final ShardingConsumerController$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

ShardingConsumerController$

public ShardingConsumerController$()

Method Details

apply

public <A,
B>
Behavior<ConsumerController.SequencedMessage<A>> apply(scala.Function1<ActorRef<ConsumerController.Start<A>>,Behavior<B>> consumerBehavior)

The Behavior of the entity that is to be initialized in ClusterSharding. It will manage the lifecycle and message delivery to the destination consumer actor.

withSettings

public <A,
B>
Behavior<ConsumerController.SequencedMessage<A>> withSettings(ShardingConsumerController.Settings settings,
 scala.Function1<ActorRef<ConsumerController.Start<A>>,Behavior<B>> consumerBehavior)

The Behavior of the entity that is to be initialized in ClusterSharding. It will manage the lifecycle and message delivery to the destination consumer actor.

create

public <A,
B>
Behavior<ConsumerController.SequencedMessage<A>> create(Function<ActorRef<ConsumerController.Start<A>>,Behavior<B>> consumerBehavior)

Java API: The Behavior of the entity that is to be initialized in ClusterSharding. It will manage the lifecycle and message delivery to the destination consumer actor.

create

public <A,
B>
Behavior<ConsumerController.SequencedMessage<A>> create(Function<ActorRef<ConsumerController.Start<A>>,Behavior<B>> consumerBehavior,
 ShardingConsumerController.Settings settings)

Java API: The Behavior of the entity that is to be initialized in ClusterSharding. It will manage the lifecycle and message delivery to the destination consumer actor.

entityTypeKeyClass

public <A>
Class<ConsumerController.SequencedMessage<A>> entityTypeKeyClass()

Java API: The generic Class type for ConsumerController.SequencedMessage that can be used when creating an EntityTypeKey for the ShardedConsumerController with Class<EntityTypeKey<ConsumerController.SequencedMessage>>.