public abstract class DowningProvider
extends java.lang.Object
ActorSystem
.Constructor and Description |
---|
DowningProvider() |
Modifier and Type | Method and Description |
---|---|
abstract scala.Option<Props> |
downingActorProps()
If a props is returned it is created as a child of the core cluster daemon on cluster startup.
|
abstract scala.concurrent.duration.FiniteDuration |
downRemovalMargin()
Time margin after which shards or singletons that belonged to a downed/removed
partition are created in surviving partition.
|
static DowningProvider |
load(java.lang.String fqcn,
ActorSystem system) |
public static DowningProvider load(java.lang.String fqcn, ActorSystem system)
fqcn
- Fully qualified class name of the implementation to be loaded.system
- Actor system used to load the implemntationConfigurationException
if loading it failspublic abstract scala.concurrent.duration.FiniteDuration downRemovalMargin()
public abstract scala.Option<Props> downingActorProps()
Cluster
APIs.
The actor will run on the same dispatcher as the cluster actor if dispatcher not configured.
May throw an exception which will then immediately lead to Cluster stopping, as the downing provider is vital to a working cluster.