Package org.apache.pekko.actor.typed.delivery.internal

Class ProducerControllerImpl<A>

java.lang.Object

org.apache.pekko.actor.typed.delivery.internal.ProducerControllerImpl<A>

public class ProducerControllerImpl<A>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ProducerControllerImpl.Ack
static class	ProducerControllerImpl.Ack$
static interface	ProducerControllerImpl.InternalCommand
static final class	ProducerControllerImpl.Request
static class	ProducerControllerImpl.Request$
static final 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, 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(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(String producerId, scala.Option<Behavior<DurableProducerQueue.Command<A>>> durableQueueBehavior, ProducerController.Settings settings, scala.reflect.ClassTag<A> evidence$1)
static <A> scala.collection.immutable.Seq<org.apache.pekko.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 Details

ProducerControllerImpl

public ProducerControllerImpl(ActorContext<ProducerControllerImpl.InternalCommand> context,
 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 Details

apply

public static <A>
Behavior<ProducerController.Command<A>> apply(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(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<org.apache.pekko.actor.typed.delivery.internal.ChunkedMessage> createChunks(A m,
 int chunkSize,
 Serialization serialization)