akka.cluster.sharding

Class ConstantRateEntityRecoveryStrategy

java.lang.Object

akka.cluster.sharding.ConstantRateEntityRecoveryStrategy

All Implemented Interfaces:

EntityRecoveryStrategy

public final class ConstantRateEntityRecoveryStrategy
extends java.lang.Object
implements EntityRecoveryStrategy

Constructor Summary

Constructors

Constructor and Description
ConstantRateEntityRecoveryStrategy(ActorSystem actorSystem, scala.concurrent.duration.FiniteDuration frequency, int numberOfEntities)

Method Summary

Modifier and Type	Method and Description
scala.collection.immutable.Set<scala.concurrent.Future<scala.collection.immutable.Set<java.lang.String>>>	recoverEntities(scala.collection.immutable.Set<java.lang.String> entities)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConstantRateEntityRecoveryStrategy

public ConstantRateEntityRecoveryStrategy(ActorSystem actorSystem,
                                          scala.concurrent.duration.FiniteDuration frequency,
                                          int numberOfEntities)

Method Detail

recoverEntities

public scala.collection.immutable.Set<scala.concurrent.Future<scala.collection.immutable.Set<java.lang.String>>> recoverEntities(scala.collection.immutable.Set<java.lang.String> entities)

Specified by:

recoverEntities in interface EntityRecoveryStrategy