Class ShardedDaemonProcessImpl

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T> void init​(java.lang.Class<T> messageClass, java.lang.String name, int numberOfInstances, Function<java.lang.Integer,​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, Function<java.lang.Integer,​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.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.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • 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
        Parameters:
        name - (undocumented)
        numberOfInstances - (undocumented)
        behaviorFactory - Given a unique id of 0 until numberOfInstance create the behavior for that actor.
        classTag - (undocumented)
      • 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
        Parameters:
        name - (undocumented)
        numberOfInstances - (undocumented)
        behaviorFactory - Given a unique id of 0 until numberOfInstance create the behavior for that actor.
        settings - (undocumented)
        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.
        classTag - (undocumented)
      • init

        public <T> void init​(java.lang.Class<T> messageClass,
                             java.lang.String name,
                             int numberOfInstances,
                             Function<java.lang.Integer,​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
        Parameters:
        messageClass - (undocumented)
        name - (undocumented)
        numberOfInstances - (undocumented)
        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,
                             Function<java.lang.Integer,​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
        Parameters:
        messageClass - (undocumented)
        name - (undocumented)
        numberOfInstances - (undocumented)
        behaviorFactory - Given a unique id of 0 until numberOfInstance create the behavior for that actor.
        settings - (undocumented)
        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.