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

Class ConsumerControllerImpl<A>

java.lang.Object

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

public class ConsumerControllerImpl<A>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ConsumerControllerImpl.InternalCommand
static interface	ConsumerControllerImpl.UnsealedInternalCommand	For commands defined in public ConsumerController

Constructor Summary

Constructors

Constructor	Description
ConsumerControllerImpl()

Method Summary

Modifier and Type	Method	Description
static <A> Behavior<ConsumerController.Command<A>>	apply(scala.Option<ServiceKey<ConsumerController.Command<A>>> serviceKey, ConsumerController.Settings settings)
static void	enforceLocalConsumer(ActorRef<?> ref)

Methods inherited from class java.lang.Object

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

Constructor Details

ConsumerControllerImpl

public ConsumerControllerImpl()

Method Details

apply

public static <A>
Behavior<ConsumerController.Command<A>> apply(scala.Option<ServiceKey<ConsumerController.Command<A>>> serviceKey,
 ConsumerController.Settings settings)

enforceLocalConsumer

public static void enforceLocalConsumer(ActorRef<?> ref)