Package akka.cluster.sharding.typed.internal

Class ShardedDaemonProcessImpl

java.lang.Object

akka.cluster.sharding.typed.javadsl.ShardedDaemonProcess

akka.cluster.sharding.typed.internal.ShardedDaemonProcessImpl

All Implemented Interfaces:

Extension, ShardedDaemonProcess

public final class ShardedDaemonProcessImpl
extends ShardedDaemonProcess
implements ShardedDaemonProcess

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ShardedDaemonProcessImpl.KeepAlivePinger$
static class	ShardedDaemonProcessImpl.MessageExtractor<T>

Constructor Summary

Constructors

Constructor	Description
ShardedDaemonProcessImpl(ActorSystem<?> system)

Method Summary

Modifier and Type	Method	Description
<T> void	init(java.lang.Class<T> messageClass, java.lang.String name, int numberOfInstances, java.util.function.IntFunction<Behavior<T>> behaviorFactory)	Start a specific number of actors that is then kept alive in the cluster.
<T> void	init(java.lang.Class<T> messageClass, java.lang.String name, int numberOfInstances, java.util.function.IntFunction<Behavior<T>> behaviorFactory, ShardedDaemonProcessSettings settings, java.util.Optional<T> stopMessage)	Start a specific number of actors, each with a unique numeric id in the set, that is then kept alive in the cluster.
<T> void	init(java.lang.Class<T> messageClass, java.lang.String name, int numberOfInstances, java.util.function.IntFunction<Behavior<T>> behaviorFactory, T stopMessage)	Start a specific number of actors that is then kept alive in the cluster.
<T> void	init(java.lang.String name, int numberOfInstances, scala.Function1<java.lang.Object,Behavior<T>> behaviorFactory, ShardedDaemonProcessSettings settings, scala.Option<T> stopMessage, scala.reflect.ClassTag<T> classTag)	Start a specific number of actors, each with a unique numeric id in the set, that is then kept alive in the cluster.
<T> void	init(java.lang.String name, int numberOfInstances, scala.Function1<java.lang.Object,Behavior<T>> behaviorFactory, scala.reflect.ClassTag<T> classTag)	Start a specific number of actors that is then kept alive in the cluster.
<T> void	init(java.lang.String name, int numberOfInstances, scala.Function1<java.lang.Object,Behavior<T>> behaviorFactory, T stopMessage, scala.reflect.ClassTag<T> classTag)	Start a specific number of actors that is then kept alive in the cluster.

Methods inherited from class akka.cluster.sharding.typed.javadsl.ShardedDaemonProcess

get

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.cluster.sharding.typed.scaladsl.ShardedDaemonProcess

asJava

Constructor Detail

ShardedDaemonProcessImpl

public ShardedDaemonProcessImpl(ActorSystem<?> system)

Method Detail

init

public <T> void init(java.lang.String name,
                     int numberOfInstances,
                     scala.Function1<java.lang.Object,Behavior<T>> behaviorFactory,
                     scala.reflect.ClassTag<T> classTag)

Description copied from interface: ShardedDaemonProcess

Start a specific number of actors that is then kept alive in the cluster.

Specified by:

init in interface ShardedDaemonProcess

behaviorFactory - Given a unique id of 0 until numberOfInstance create the behavior for that actor.

init

public <T> void init(java.lang.String name,
                     int numberOfInstances,
                     scala.Function1<java.lang.Object,Behavior<T>> behaviorFactory,
                     T stopMessage,
                     scala.reflect.ClassTag<T> classTag)

Description copied from interface: ShardedDaemonProcess

Start a specific number of actors that is then kept alive in the cluster.

Specified by:

init in interface ShardedDaemonProcess

behaviorFactory - Given a unique id of 0 until numberOfInstance create the behavior for that actor.

stopMessage - sent to the actors when they need to stop because of a rebalance across the nodes of the cluster or cluster shutdown.

init

public <T> void init(java.lang.String name,
                     int numberOfInstances,
                     scala.Function1<java.lang.Object,Behavior<T>> behaviorFactory,
                     ShardedDaemonProcessSettings settings,
                     scala.Option<T> stopMessage,
                     scala.reflect.ClassTag<T> classTag)

Description copied from interface: ShardedDaemonProcess

Start a specific number of actors, each with a unique numeric id in the set, that is then kept alive in the cluster.

Specified by:

init in interface ShardedDaemonProcess

behaviorFactory - Given a unique id of 0 until numberOfInstance create the behavior for that actor.

stopMessage - if defined sent to the actors when they need to stop because of a rebalance across the nodes of the cluster or cluster shutdown.

init

public <T> void init(java.lang.Class<T> messageClass,
                     java.lang.String name,
                     int numberOfInstances,
                     java.util.function.IntFunction<Behavior<T>> behaviorFactory)

Description copied from class: ShardedDaemonProcess

Start a specific number of actors that is then kept alive in the cluster.

Specified by:

init in class ShardedDaemonProcess

behaviorFactory - Given a unique id of 0 until numberOfInstance create the behavior for that actor.

init

public <T> void init(java.lang.Class<T> messageClass,
                     java.lang.String name,
                     int numberOfInstances,
                     java.util.function.IntFunction<Behavior<T>> behaviorFactory,
                     T stopMessage)

Description copied from class: ShardedDaemonProcess

Start a specific number of actors that is then kept alive in the cluster.

Specified by:

init in class ShardedDaemonProcess

behaviorFactory - Given a unique id of 0 until numberOfInstance create the behavior for that actor.

stopMessage - sent to the actors when they need to stop because of a rebalance across the nodes of the cluster or cluster shutdown.

init

public <T> void init(java.lang.Class<T> messageClass,
                     java.lang.String name,
                     int numberOfInstances,
                     java.util.function.IntFunction<Behavior<T>> behaviorFactory,
                     ShardedDaemonProcessSettings settings,
                     java.util.Optional<T> stopMessage)

Description copied from class: ShardedDaemonProcess

Start a specific number of actors, each with a unique numeric id in the set, that is then kept alive in the cluster.

Specified by:

init in class ShardedDaemonProcess

behaviorFactory - Given a unique id of 0 until numberOfInstance create the behavior for that actor.

stopMessage - if defined sent to the actors when they need to stop because of a rebalance across the nodes of the cluster or cluster shutdown.