Package akka.actor.typed.delivery.internal

Class ProducerControllerImpl<A>

java.lang.Object

akka.actor.typed.delivery.internal.ProducerControllerImpl<A>

public class ProducerControllerImpl<A>
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ProducerControllerImpl.Ack
static class	ProducerControllerImpl.Ack$
static interface	ProducerControllerImpl.InternalCommand
static class	ProducerControllerImpl.Request
static class	ProducerControllerImpl.Request$
static class	ProducerControllerImpl.Resend
static class	ProducerControllerImpl.Resend$
static class	ProducerControllerImpl.ResendFirstUnconfirmed$
static interface	ProducerControllerImpl.UnsealedInternalCommand	For commands defined in public ProducerController

Constructor Summary

Constructors

Constructor	Description
ProducerControllerImpl(ActorContext<ProducerControllerImpl.InternalCommand> context, java.lang.String producerId, scala.Option<ActorRef<DurableProducerQueue.Command<A>>> durableQueue, ProducerController.Settings settings, ActorRef<A> msgAdapter, TimerScheduler<ProducerControllerImpl.InternalCommand> timers, scala.reflect.ClassTag<A> evidence$5)

Method Summary

Modifier and Type	Method	Description
static <A> Behavior<ProducerController.Command<A>>	apply(java.lang.String producerId, scala.Option<Behavior<DurableProducerQueue.Command<A>>> durableQueueBehavior, ProducerController.Settings settings, scala.Function1<ConsumerController.SequencedMessage<A>,scala.runtime.BoxedUnit> send, scala.reflect.ClassTag<A> evidence$2)	For custom send function.
static <A> Behavior<ProducerController.Command<A>>	apply(java.lang.String producerId, scala.Option<Behavior<DurableProducerQueue.Command<A>>> durableQueueBehavior, ProducerController.Settings settings, scala.reflect.ClassTag<A> evidence$1)
static <A> scala.collection.immutable.Seq<akka.actor.typed.delivery.internal.ChunkedMessage>	createChunks(A m, int chunkSize, Serialization serialization)
static void	enforceLocalProducer(ActorRef<?> ref)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProducerControllerImpl

public ProducerControllerImpl(ActorContext<ProducerControllerImpl.InternalCommand> context,
                              java.lang.String producerId,
                              scala.Option<ActorRef<DurableProducerQueue.Command<A>>> durableQueue,
                              ProducerController.Settings settings,
                              ActorRef<A> msgAdapter,
                              TimerScheduler<ProducerControllerImpl.InternalCommand> timers,
                              scala.reflect.ClassTag<A> evidence$5)

Method Detail

apply

public static <A> Behavior<ProducerController.Command<A>> apply(java.lang.String producerId,
                                                                scala.Option<Behavior<DurableProducerQueue.Command<A>>> durableQueueBehavior,
                                                                ProducerController.Settings settings,
                                                                scala.reflect.ClassTag<A> evidence$1)

apply

public static <A> Behavior<ProducerController.Command<A>> apply(java.lang.String producerId,
                                                                scala.Option<Behavior<DurableProducerQueue.Command<A>>> durableQueueBehavior,
                                                                ProducerController.Settings settings,
                                                                scala.Function1<ConsumerController.SequencedMessage<A>,scala.runtime.BoxedUnit> send,
                                                                scala.reflect.ClassTag<A> evidence$2)

For custom send function. For example used with Sharding where the message must be wrapped in ShardingEnvelope(SequencedMessage(msg)).

enforceLocalProducer

public static void enforceLocalProducer(ActorRef<?> ref)

createChunks

public static <A> scala.collection.immutable.Seq<akka.actor.typed.delivery.internal.ChunkedMessage> createChunks(A m,
                                                                                                                 int chunkSize,
                                                                                                                 Serialization serialization)