Package akka.cluster.sharding

Class Shard.Entities

java.lang.Object

akka.cluster.sharding.Shard.Entities

Enclosing class:

Shard

public static final class Shard.Entities
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
Entities(LoggingAdapter log, boolean rememberingEntities, boolean verboseDebug, boolean failOnIllegalTransition)

Method Summary

Modifier and Type	Method	Description
scala.collection.immutable.Set<ActorRef>	activeEntities()
scala.collection.immutable.Set<java.lang.String>	activeEntityIds()
void	addEntity(java.lang.String entityId, ActorRef ref)
void	alreadyRemembered(scala.collection.immutable.Set<java.lang.String> set)
OptionVal<ActorRef>	entity(java.lang.String entityId)
OptionVal<java.lang.String>	entityId(ActorRef ref)
boolean	entityIdExists(java.lang.String id)
void	entityPassivating(java.lang.String entityId)
Shard.EntityState	entityState(java.lang.String id)
boolean	failOnIllegalTransition()
boolean	isPassivating(java.lang.String id)
LoggingAdapter	log()
int	nrActiveEntities()
boolean	pendingRememberedEntitiesExist()
scala.Tuple2<scala.collection.immutable.Map<java.lang.String,Shard.RememberingStart>,scala.collection.immutable.Set<java.lang.String>>	pendingRememberEntities()
boolean	rememberingEntities()
void	rememberingStart(java.lang.String entityId, scala.Option<ActorRef> ackTo)
void	rememberingStop(java.lang.String entityId)
void	removeEntity(java.lang.String entityId)
int	size()
java.lang.String	toString()
void	waitingForRestart(java.lang.String id)

Methods inherited from class java.lang.Object

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

Constructor Detail

Entities

public Entities(LoggingAdapter log,
                boolean rememberingEntities,
                boolean verboseDebug,
                boolean failOnIllegalTransition)

Method Detail

activeEntities

public scala.collection.immutable.Set<ActorRef> activeEntities()

activeEntityIds

public scala.collection.immutable.Set<java.lang.String> activeEntityIds()

addEntity

public void addEntity(java.lang.String entityId,
                      ActorRef ref)

alreadyRemembered

public void alreadyRemembered(scala.collection.immutable.Set<java.lang.String> set)

entity

public OptionVal<ActorRef> entity(java.lang.String entityId)

entityId

public OptionVal<java.lang.String> entityId(ActorRef ref)

entityIdExists

public boolean entityIdExists(java.lang.String id)

entityPassivating

public void entityPassivating(java.lang.String entityId)

entityState

public Shard.EntityState entityState(java.lang.String id)

failOnIllegalTransition

public boolean failOnIllegalTransition()

isPassivating

public boolean isPassivating(java.lang.String id)

log

public LoggingAdapter log()

nrActiveEntities

public int nrActiveEntities()

pendingRememberEntities

public scala.Tuple2<scala.collection.immutable.Map<java.lang.String,Shard.RememberingStart>,scala.collection.immutable.Set<java.lang.String>> pendingRememberEntities()

Returns:

(remembering start, remembering stop)

pendingRememberedEntitiesExist

public boolean pendingRememberedEntitiesExist()

rememberingEntities

public boolean rememberingEntities()

rememberingStart

public void rememberingStart(java.lang.String entityId,
                             scala.Option<ActorRef> ackTo)

rememberingStop

public void rememberingStop(java.lang.String entityId)

removeEntity

public void removeEntity(java.lang.String entityId)

size

public int size()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

waitingForRestart

public void waitingForRestart(java.lang.String id)