Package org.apache.pekko.cluster.sharding.typed

Class ChangeNumberOfProcesses

java.lang.Object
org.apache.pekko.cluster.sharding.typed.ChangeNumberOfProcesses
All Implemented Interfaces:
ClusterShardingTypedSerializable, ShardedDaemonProcessCommand
public final class ChangeNumberOfProcesses extends 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 Details

    • ChangeNumberOfProcesses

      public ChangeNumberOfProcesses(int newNumberOfProcesses, ActorRef<StatusReply<Done>> replyTo)

  • Method Details

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

    • replyTo

      public ActorRef<StatusReply<Done>> replyTo()

    • equals

      public boolean equals(Object other)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object