Package akka.cluster.sharding.typed
Class ChangeNumberOfProcesses
- java.lang.Object
-
- akka.cluster.sharding.typed.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 Summary
Constructors Constructor Description ChangeNumberOfProcesses(int newNumberOfProcesses, ActorRef<StatusReply<Done>> replyTo)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static ChangeNumberOfProcesses
apply(int newNumberOfProcesses, ActorRef<StatusReply<Done>> replyTo)
Scala API: Tell the sharded daemon process to rescale to the given number of processes.boolean
equals(java.lang.Object other)
int
hashCode()
int
newNumberOfProcesses()
ActorRef<StatusReply<Done>>
replyTo()
-
-
-
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 toreplyTo
- 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(java.lang.Object other)
- Overrides:
equals
in classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
-