java.lang.Object
- akka.cluster.ddata.ReplicatorSettings

```
public final class ReplicatorSettings
extends java.lang.Object
```
param: roles Replicas are running on members tagged with these roles. The member must have all given roles. All members are used if empty. param: gossipInterval How often the Replicator should send out gossip information. param: notifySubscribersInterval How often the subscribers will be notified of changes, if any. param: maxDeltaElements Maximum number of entries to transfer in one gossip message when synchronizing the replicas. Next chunk will be transferred in next round of gossip. param: dispatcher Id of the dispatcher to use for Replicator actors. If not specified ("") the default dispatcher is used. param: pruningInterval How often the Replicator checks for pruning of data associated with removed cluster nodes. param: maxPruningDissemination How long time it takes (worst case) to spread the data to all other replica nodes. This is used when initiating and completing the pruning process of data associated with removed cluster nodes. The time measurement is stopped when any replica is unreachable, so it should be configured to worst case in a healthy cluster. param: durableStoreProps Props for the durable store actor, the Left alternative is a tuple of fully qualified actor class name and the config constructor parameter of that class, the Right alternative is the Props of the actor. param: durableKeys Keys that are durable. Prefix matching is supported by using * at the end of a key. All entries can be made durable by including "*" in the Set. param: preferOldest Update and Get operations are sent to oldest nodes first. param: logDataSizeExceeding Log data size. param: expiryKeys Map of keys and inactivity duration for entries that will automatically be removed without tombstones when they have been inactive for the given duration. Prefix matching is supported by using * at the end of a key. Matching tombstones will also be removed after the expiry duration.

Constructor Summary

Constructors
Constructor	Description
ReplicatorSettings(scala.collection.immutable.Set<java.lang.String> roles, scala.concurrent.duration.FiniteDuration gossipInterval, scala.concurrent.duration.FiniteDuration notifySubscribersInterval, int maxDeltaElements, java.lang.String dispatcher, scala.concurrent.duration.FiniteDuration pruningInterval, scala.concurrent.duration.FiniteDuration maxPruningDissemination, scala.util.Either<scala.Tuple2<java.lang.String,com.typesafe.config.Config>,Props> durableStoreProps, scala.collection.immutable.Set<java.lang.String> durableKeys, scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive, boolean deltaCrdtEnabled, int maxDeltaSize)	Deprecated. use full constructor.
ReplicatorSettings(scala.collection.immutable.Set<java.lang.String> roles, scala.concurrent.duration.FiniteDuration gossipInterval, scala.concurrent.duration.FiniteDuration notifySubscribersInterval, int maxDeltaElements, java.lang.String dispatcher, scala.concurrent.duration.FiniteDuration pruningInterval, scala.concurrent.duration.FiniteDuration maxPruningDissemination, scala.util.Either<scala.Tuple2<java.lang.String,com.typesafe.config.Config>,Props> durableStoreProps, scala.collection.immutable.Set<java.lang.String> durableKeys, scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive, boolean deltaCrdtEnabled, int maxDeltaSize, boolean preferOldest)	Deprecated. use full constructor.
ReplicatorSettings(scala.collection.immutable.Set<java.lang.String> roles, scala.concurrent.duration.FiniteDuration gossipInterval, scala.concurrent.duration.FiniteDuration notifySubscribersInterval, int maxDeltaElements, java.lang.String dispatcher, scala.concurrent.duration.FiniteDuration pruningInterval, scala.concurrent.duration.FiniteDuration maxPruningDissemination, scala.util.Either<scala.Tuple2<java.lang.String,com.typesafe.config.Config>,Props> durableStoreProps, scala.collection.immutable.Set<java.lang.String> durableKeys, scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive, boolean deltaCrdtEnabled, int maxDeltaSize, boolean preferOldest, scala.Option<java.lang.Object> logDataSizeExceeding)	Deprecated. use full constructor.
ReplicatorSettings(scala.collection.immutable.Set<java.lang.String> roles, scala.concurrent.duration.FiniteDuration gossipInterval, scala.concurrent.duration.FiniteDuration notifySubscribersInterval, int maxDeltaElements, java.lang.String dispatcher, scala.concurrent.duration.FiniteDuration pruningInterval, scala.concurrent.duration.FiniteDuration maxPruningDissemination, scala.util.Either<scala.Tuple2<java.lang.String,com.typesafe.config.Config>,Props> durableStoreProps, scala.collection.immutable.Set<java.lang.String> durableKeys, scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive, boolean deltaCrdtEnabled, int maxDeltaSize, boolean preferOldest, scala.Option<java.lang.Object> logDataSizeExceeding, scala.collection.immutable.Map<java.lang.String,scala.concurrent.duration.FiniteDuration> expiryKeys)
`ReplicatorSettings(scala.Option<java.lang.String> role, scala.concurrent.duration.FiniteDuration gossipInterval, scala.concurrent.duration.FiniteDuration notifySubscribersInterval, int maxDeltaElements, java.lang.String dispatcher, scala.concurrent.duration.FiniteDuration pruningInterval, scala.concurrent.duration.FiniteDuration maxPruningDissemination)`	Deprecated. use full constructor.
ReplicatorSettings(scala.Option<java.lang.String> role, scala.concurrent.duration.FiniteDuration gossipInterval, scala.concurrent.duration.FiniteDuration notifySubscribersInterval, int maxDeltaElements, java.lang.String dispatcher, scala.concurrent.duration.FiniteDuration pruningInterval, scala.concurrent.duration.FiniteDuration maxPruningDissemination, scala.util.Either<scala.Tuple2<java.lang.String,com.typesafe.config.Config>,Props> durableStoreProps, scala.collection.immutable.Set<java.lang.String> durableKeys)	Deprecated. use full constructor.
ReplicatorSettings(scala.Option<java.lang.String> role, scala.concurrent.duration.FiniteDuration gossipInterval, scala.concurrent.duration.FiniteDuration notifySubscribersInterval, int maxDeltaElements, java.lang.String dispatcher, scala.concurrent.duration.FiniteDuration pruningInterval, scala.concurrent.duration.FiniteDuration maxPruningDissemination, scala.util.Either<scala.Tuple2<java.lang.String,com.typesafe.config.Config>,Props> durableStoreProps, scala.collection.immutable.Set<java.lang.String> durableKeys, scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive, boolean deltaCrdtEnabled)	Deprecated. use full constructor.
ReplicatorSettings(scala.Option<java.lang.String> role, scala.concurrent.duration.FiniteDuration gossipInterval, scala.concurrent.duration.FiniteDuration notifySubscribersInterval, int maxDeltaElements, java.lang.String dispatcher, scala.concurrent.duration.FiniteDuration pruningInterval, scala.concurrent.duration.FiniteDuration maxPruningDissemination, scala.util.Either<scala.Tuple2<java.lang.String,com.typesafe.config.Config>,Props> durableStoreProps, scala.collection.immutable.Set<java.lang.String> durableKeys, scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive, boolean deltaCrdtEnabled, int maxDeltaSize)	Deprecated. use full constructor.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static ReplicatorSettings`	`apply(ActorSystem system)`	Create settings from the default configuration `akka.cluster.distributed-data`.
`static ReplicatorSettings`	`apply(com.typesafe.config.Config config)`	Create settings from a configuration with the same layout as the default configuration `akka.cluster.distributed-data`.
`boolean`	`deltaCrdtEnabled()`
`java.lang.String`	`dispatcher()`
`scala.collection.immutable.Set<java.lang.String>`	`durableKeys()`
`scala.concurrent.duration.FiniteDuration`	`durablePruningMarkerTimeToLive()`
`scala.util.Either<scala.Tuple2<java.lang.String,com.typesafe.config.Config>,Props>`	`durableStoreProps()`
`scala.collection.immutable.Map<java.lang.String,scala.concurrent.duration.FiniteDuration>`	`expiryKeys()`
`scala.concurrent.duration.FiniteDuration`	`gossipInterval()`
`scala.Option<java.lang.Object>`	`logDataSizeExceeding()`
`int`	`maxDeltaElements()`
`int`	`maxDeltaSize()`
`scala.concurrent.duration.FiniteDuration`	`maxPruningDissemination()`
`scala.concurrent.duration.FiniteDuration`	`notifySubscribersInterval()`
`boolean`	`preferOldest()`
`scala.concurrent.duration.FiniteDuration`	`pruningInterval()`
`scala.concurrent.duration.FiniteDuration`	`pruningMarkerTimeToLive()`
`scala.Option<java.lang.String>`	`role()`
`scala.collection.immutable.Set<java.lang.String>`	`roles()`
`ReplicatorSettings`	`withDeltaCrdtEnabled(boolean deltaCrdtEnabled)`
`ReplicatorSettings`	`withDispatcher(java.lang.String dispatcher)`
`ReplicatorSettings`	`withDurableKeys(java.util.Set<java.lang.String> durableKeys)`	Java API
`ReplicatorSettings`	`withDurableKeys(scala.collection.immutable.Set<java.lang.String> durableKeys)`	Scala API
`ReplicatorSettings`	`withDurableStoreProps(Props durableStoreProps)`
`ReplicatorSettings`	`withExpiryKeys(java.util.Map<java.lang.String,java.time.Duration> expiryKeys)`	Java API
`ReplicatorSettings`	`withExpiryKeys(scala.collection.immutable.Map<java.lang.String,scala.concurrent.duration.FiniteDuration> expiryKeys)`	Scala API
`ReplicatorSettings`	`withGossipInterval(scala.concurrent.duration.FiniteDuration gossipInterval)`
`ReplicatorSettings`	`withLogDataSizeExceeding(int logDataSizeExceeding)`
`ReplicatorSettings`	`withMaxDeltaElements(int maxDeltaElements)`
`ReplicatorSettings`	`withMaxDeltaSize(int maxDeltaSize)`
`ReplicatorSettings`	`withNotifySubscribersInterval(scala.concurrent.duration.FiniteDuration notifySubscribersInterval)`
`ReplicatorSettings`	`withPreferOldest(boolean preferOldest)`
`ReplicatorSettings`	`withPruning(scala.concurrent.duration.FiniteDuration pruningInterval, scala.concurrent.duration.FiniteDuration maxPruningDissemination)`
`ReplicatorSettings`	`withPruningMarkerTimeToLive(scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive)`
`ReplicatorSettings`	`withRole(java.lang.String role)`
`ReplicatorSettings`	`withRole(scala.Option<java.lang.String> role)`
`ReplicatorSettings`	`withRoles(java.lang.String... roles)`
`ReplicatorSettings`	`withRoles(scala.collection.immutable.Seq<java.lang.String> roles)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReplicatorSettings

public ReplicatorSettings(scala.collection.immutable.Set<java.lang.String> roles,
                          scala.concurrent.duration.FiniteDuration gossipInterval,
                          scala.concurrent.duration.FiniteDuration notifySubscribersInterval,
                          int maxDeltaElements,
                          java.lang.String dispatcher,
                          scala.concurrent.duration.FiniteDuration pruningInterval,
                          scala.concurrent.duration.FiniteDuration maxPruningDissemination,
                          scala.util.Either<scala.Tuple2<java.lang.String,com.typesafe.config.Config>,Props> durableStoreProps,
                          scala.collection.immutable.Set<java.lang.String> durableKeys,
                          scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive,
                          scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive,
                          boolean deltaCrdtEnabled,
                          int maxDeltaSize,
                          boolean preferOldest,
                          scala.Option<java.lang.Object> logDataSizeExceeding,
                          scala.collection.immutable.Map<java.lang.String,scala.concurrent.duration.FiniteDuration> expiryKeys)

ReplicatorSettings

public ReplicatorSettings(scala.collection.immutable.Set<java.lang.String> roles,
                          scala.concurrent.duration.FiniteDuration gossipInterval,
                          scala.concurrent.duration.FiniteDuration notifySubscribersInterval,
                          int maxDeltaElements,
                          java.lang.String dispatcher,
                          scala.concurrent.duration.FiniteDuration pruningInterval,
                          scala.concurrent.duration.FiniteDuration maxPruningDissemination,
                          scala.util.Either<scala.Tuple2<java.lang.String,com.typesafe.config.Config>,Props> durableStoreProps,
                          scala.collection.immutable.Set<java.lang.String> durableKeys,
                          scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive,
                          scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive,
                          boolean deltaCrdtEnabled,
                          int maxDeltaSize,
                          boolean preferOldest,
                          scala.Option<java.lang.Object> logDataSizeExceeding)

Deprecated.

use full constructor. Since 2.7.1.