Package akka.actor.typed.internal.routing

Class PoolRouterImpl<T>

java.lang.Object

akka.actor.typed.Behavior<T>

akka.actor.typed.ExtensibleBehavior<T>

akka.actor.typed.scaladsl.AbstractBehavior<T>

akka.actor.typed.internal.routing.PoolRouterImpl<T>

public final class PoolRouterImpl<T>
extends AbstractBehavior<T>

INTERNAL API

Nested Class Summary

Nested classes/interfaces inherited from class akka.actor.typed.Behavior

Behavior.BehaviorDecorators<Inner>, Behavior.BehaviorDecorators$

Constructor Summary

Constructors

Constructor	Description
PoolRouterImpl(ActorContext<T> ctx, int poolSize, Behavior<T> behavior, RoutingLogic<T> logic, scala.Function1<T,java.lang.Object> broadcastPredicate, Props routeeProps)

Method Summary

Modifier and Type	Method	Description
Behavior<T>	onMessage(T msg)	Implement this method to process an incoming message and return the next behavior.
scala.PartialFunction<Signal,Behavior<T>>	onSignal()	Override this method to process an incoming Signal and return the next behavior.

Methods inherited from class akka.actor.typed.scaladsl.AbstractBehavior

context, receive, receiveSignal

Methods inherited from class akka.actor.typed.Behavior

BehaviorDecorators, canonicalize, existsInStack, interpretMessage, interpretSignal, isAlive, isDeferred, isUnhandled, narrow, start, validateAsInitial

Methods inherited from class java.lang.Object

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

Constructor Detail

PoolRouterImpl

public PoolRouterImpl(ActorContext<T> ctx,
                      int poolSize,
                      Behavior<T> behavior,
                      RoutingLogic<T> logic,
                      scala.Function1<T,java.lang.Object> broadcastPredicate,
                      Props routeeProps)

Method Detail

onMessage

public Behavior<T> onMessage(T msg)

Description copied from class: AbstractBehavior

Implement this method to process an incoming message and return the next behavior.

The returned behavior can in addition to normal behaviors be one of the canned special objects:

• returning stopped will terminate this Behavior
• returning this or same designates to reuse the current Behavior
• returning unhandled keeps the same Behavior and signals that the message was not yet handled

Specified by:

onMessage in class AbstractBehavior<T>

onSignal

public scala.PartialFunction<Signal,Behavior<T>> onSignal()

Description copied from class: AbstractBehavior

Override this method to process an incoming Signal and return the next behavior. This means that all lifecycle hooks, ReceiveTimeout, Terminated and Failed messages can initiate a behavior change.

The returned behavior can in addition to normal behaviors be one of the canned special objects:

* returning stopped will terminate this Behavior * returning this or same designates to reuse the current Behavior * returning unhandled keeps the same Behavior and signals that the message was not yet handled

By default, partial function is empty and does not handle any signals.

Overrides:

onSignal in class AbstractBehavior<T>