Class ShardingConsumerControllerImpl<A>
java.lang.Object
org.apache.pekko.cluster.sharding.typed.delivery.internal.ShardingConsumerControllerImpl<A>
-
Constructor Summary
ConstructorsConstructorDescriptionShardingConsumerControllerImpl(ActorContext<ConsumerController.Command<A>> context, ActorRef<ConsumerController.Delivery<A>> deliverTo, ShardingConsumerController.Settings settings) -
Method Summary
Modifier and TypeMethodDescriptionactive(scala.collection.immutable.Map<ActorRef<ProducerControllerImpl.InternalCommand>, String> producerControllers, scala.collection.immutable.Map<String, ActorRef<ConsumerController.Command<A>>> consumerControllers) static <A,B> Behavior<ConsumerController.SequencedMessage<A>> apply(scala.Function1<ActorRef<ConsumerController.Start<A>>, Behavior<B>> consumerBehavior, ShardingConsumerController.Settings settings)
-
Constructor Details
-
ShardingConsumerControllerImpl
public ShardingConsumerControllerImpl(ActorContext<ConsumerController.Command<A>> context, ActorRef<ConsumerController.Delivery<A>> deliverTo, ShardingConsumerController.Settings settings)
-
-
Method Details
-
apply
public static <A,B> Behavior<ConsumerController.SequencedMessage<A>> apply(scala.Function1<ActorRef<ConsumerController.Start<A>>, Behavior<B>> consumerBehavior, ShardingConsumerController.Settings settings) -
active
public Behavior<ConsumerController.Command<A>> active(scala.collection.immutable.Map<ActorRef<ProducerControllerImpl.InternalCommand>, String> producerControllers, scala.collection.immutable.Map<String, ActorRef<ConsumerController.Command<A>>> consumerControllers)
-