public interface LeveldbIdMapping
extends akka.actor.Actor
LevelDB backed persistent mapping of String
-based persistent actor ids to numeric ids.
Modifier and Type | Method and Description |
---|---|
scala.collection.immutable.Set<java.lang.String> |
allPersistenceIds() |
scala.collection.immutable.Map<java.lang.String,java.lang.Object> |
idMap() |
java.lang.Object |
idMapLock() |
int |
idOffset() |
boolean |
isNewPersistenceId(java.lang.String id) |
void |
newPersistenceIdAdded(java.lang.String id) |
int |
numericId(java.lang.String id)
Get the mapped numeric id for the specified persistent actor
id . |
void |
preStart() |
scala.collection.immutable.Map<java.lang.String,java.lang.Object> |
readIdMap() |
scala.collection.immutable.Map<java.lang.String,java.lang.Object> |
readIdMap(scala.collection.immutable.Map<java.lang.String,java.lang.Object> pathMap,
org.iq80.leveldb.DBIterator iter) |
int |
writeIdMapping(java.lang.String id,
int numericId) |
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, receive, self, sender, supervisorStrategy, unhandled
int idOffset()
scala.collection.immutable.Map<java.lang.String,java.lang.Object> idMap()
java.lang.Object idMapLock()
int numericId(java.lang.String id)
id
. Creates and
stores a new mapping if necessary.
This method is thread safe and it is allowed to call it from a another
thread than the actor's thread. That is necessary for Future composition,
e.g. asyncReadHighestSequenceNr
followed by asyncReplayMessages
.
id
- (undocumented)boolean isNewPersistenceId(java.lang.String id)
scala.collection.immutable.Set<java.lang.String> allPersistenceIds()
scala.collection.immutable.Map<java.lang.String,java.lang.Object> readIdMap()
scala.collection.immutable.Map<java.lang.String,java.lang.Object> readIdMap(scala.collection.immutable.Map<java.lang.String,java.lang.Object> pathMap, org.iq80.leveldb.DBIterator iter)
int writeIdMapping(java.lang.String id, int numericId)
void newPersistenceIdAdded(java.lang.String id)
void preStart()
preStart
in interface akka.actor.Actor