Class PoolRouterImpl<T>

    • 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>