Class ChangeNumberOfProcesses

  • All Implemented Interfaces:
    ClusterShardingTypedSerializable, ShardedDaemonProcessCommand

    public final class ChangeNumberOfProcesses
    extends java.lang.Object
    implements ShardedDaemonProcessCommand, ClusterShardingTypedSerializable
    Tell the sharded daemon process to rescale to the given number of processes.

    param: newNumberOfProcesses The number of processes to scale up to param: replyTo Reply to this actor once scaling is successfully done, or with details if it failed Note that a successful response may take a long time, depending on how fast the daemon process actors stop after getting their stop message.

    • Constructor Detail

      • ChangeNumberOfProcesses

        public ChangeNumberOfProcesses​(int newNumberOfProcesses,
                                       ActorRef<StatusReply<Done>> replyTo)
    • Method Detail

      • apply

        public static ChangeNumberOfProcesses apply​(int newNumberOfProcesses,
                                                    ActorRef<StatusReply<Done>> replyTo)
        Scala API: Tell the sharded daemon process to rescale to the given number of processes.

        Parameters:
        newNumberOfProcesses - The number of processes to scale up to
        replyTo - Reply to this actor once scaling is successfully done, or with details if it failed Note that a successful response may take a long time, depending on how fast the daemon process actors stop after getting their stop message.
      • newNumberOfProcesses

        public int newNumberOfProcesses()
      • equals

        public boolean equals​(java.lang.Object other)
        Overrides:
        equals in class java.lang.Object
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object