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

Class ShardingProducerControllerImpl<A>

java.lang.Object

org.apache.pekko.cluster.sharding.typed.delivery.internal.ShardingProducerControllerImpl<A>

public class ShardingProducerControllerImpl<A>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ShardingProducerControllerImpl.InternalCommand
static interface	ShardingProducerControllerImpl.UnsealedInternalCommand	For commands defined in public ShardingProducerController

Constructor Summary

Constructors

Constructor	Description
ShardingProducerControllerImpl(ActorContext<ShardingProducerControllerImpl.InternalCommand> context, String producerId, ActorRef<ShardingEnvelope<A>> msgAdapter, ActorRef<ShardingEnvelope<ConsumerController.SequencedMessage<A>>> region, scala.Option<ActorRef<DurableProducerQueue.Command<A>>> durableQueue, ShardingProducerController.Settings settings, scala.reflect.ClassTag<A> evidence$3)

Method Summary

Modifier and Type	Method	Description
static <A> Behavior<ShardingProducerController.Command<A>>	apply(String producerId, ActorRef<ShardingEnvelope<ConsumerController.SequencedMessage<A>>> region, scala.Option<Behavior<DurableProducerQueue.Command<A>>> durableQueueBehavior, ShardingProducerController.Settings settings, scala.reflect.ClassTag<A> evidence$1)

Methods inherited from class java.lang.Object

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

Constructor Details

ShardingProducerControllerImpl

public ShardingProducerControllerImpl(ActorContext<ShardingProducerControllerImpl.InternalCommand> context,
 String producerId,
 ActorRef<ShardingEnvelope<A>> msgAdapter,
 ActorRef<ShardingEnvelope<ConsumerController.SequencedMessage<A>>> region,
 scala.Option<ActorRef<DurableProducerQueue.Command<A>>> durableQueue,
 ShardingProducerController.Settings settings,
 scala.reflect.ClassTag<A> evidence$3)

Method Details

apply

public static <A>
Behavior<ShardingProducerController.Command<A>> apply(String producerId,
 ActorRef<ShardingEnvelope<ConsumerController.SequencedMessage<A>>> region,
 scala.Option<Behavior<DurableProducerQueue.Command<A>>> durableQueueBehavior,
 ShardingProducerController.Settings settings,
 scala.reflect.ClassTag<A> evidence$1)