Package akka.cluster.sharding.typed.delivery.internal

Class ShardingProducerControllerImpl<A>

java.lang.Object

akka.cluster.sharding.typed.delivery.internal.ShardingProducerControllerImpl<A>

public class ShardingProducerControllerImpl<A>
extends java.lang.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, java.lang.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(java.lang.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 Detail

ShardingProducerControllerImpl

public ShardingProducerControllerImpl(ActorContext<ShardingProducerControllerImpl.InternalCommand> context,
                                      java.lang.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 Detail

apply

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