Package akka.persistence.journal.leveldb

Interface LeveldbIdMapping

All Superinterfaces:

Actor

All Known Subinterfaces:

LeveldbStore

All Known Implementing Classes:

SharedLeveldbStore

public interface LeveldbIdMapping
extends Actor

INTERNAL API.

LevelDB backed persistent mapping of String-based persistent actor ids to numeric ids.

Nested Class Summary

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$, Actor.ignoringBehavior$

Method Summary

Modifier and Type	Method	Description
scala.collection.immutable.Set<java.lang.String>	allPersistenceIds()
void	idMap_$eq(scala.collection.immutable.Map<java.lang.String,java.lang.Object> x$1)
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()	User overridable callback.
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)
void	super$preStart()	Get the mapped numeric id for the specified persistent actor id.
int	writeIdMapping(java.lang.String id, int numericId)

Methods inherited from interface akka.actor.Actor

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

Method Detail

allPersistenceIds

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

idMap_$eq

void idMap_$eq(scala.collection.immutable.Map<java.lang.String,java.lang.Object> x$1)

isNewPersistenceId

boolean isNewPersistenceId(java.lang.String id)

newPersistenceIdAdded

void newPersistenceIdAdded(java.lang.String id)

numericId

int numericId(java.lang.String id)

Get the mapped numeric id for the specified persistent actor 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.

preStart

void preStart()

Description copied from interface: Actor

User overridable callback.

Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.

Specified by:

preStart in interface Actor

readIdMap

scala.collection.immutable.Map<java.lang.String,java.lang.Object> readIdMap()

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)

super$preStart

void super$preStart()

Get the mapped numeric id for the specified persistent actor 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.

writeIdMapping

int writeIdMapping(java.lang.String id,
                   int numericId)