Package akka.actor.typed.delivery.internal

Class ConsumerControllerImpl<A>

java.lang.Object

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

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

ConsumerControllerImpl

public ConsumerControllerImpl()

Method Detail

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)