akka.persistence.journal.leveldb
Class SharedLeveldbStore

java.lang.Object
  extended by akka.persistence.journal.leveldb.SharedLeveldbStore
All Implemented Interfaces:
Actor, AsyncRecovery, LeveldbIdMapping, LeveldbRecovery, LeveldbStore

public class SharedLeveldbStore
extends java.lang.Object
implements LeveldbStore

A LevelDB store that can be shared by multiple actor systems. The shared store must be set for each actor system that uses the store via SharedLeveldbJournal.setStore. The shared LevelDB store is for testing only.


Nested Class Summary
 
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$
 
Constructor Summary
SharedLeveldbStore()
           
 
Method Summary
 java.lang.String configPath()
           
 scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
          This defines the initial actor behavior, it must return a partial function with the actor logic.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface akka.persistence.journal.leveldb.LeveldbStore
addToConfirmationBatch, addToMessageBatch, config, deleteMessages, deleteMessagesTo, leveldb, leveldbDir, leveldbFactory, leveldbOptions, leveldbReadOptions, leveldbSnapshot, leveldbWriteOptions, nativeLeveldb, persistentFromBytes, persistentToBytes, postStop, preStart, serialization, withBatch, withIterator, writeConfirmations, writeMessages
 
Methods inherited from interface akka.persistence.journal.leveldb.LeveldbIdMapping
idMap, idOffset, numericId, readIdMap, readIdMap, writeIdMapping
 
Methods inherited from interface akka.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, self, sender, supervisorStrategy, unhandled
 
Methods inherited from interface akka.persistence.journal.leveldb.LeveldbRecovery
asyncReadHighestSequenceNr, asyncReplayMessages, readHighestSequenceNr, replayDispatcher, replayDispatcherId, replayMessages
 

Constructor Detail

SharedLeveldbStore

public SharedLeveldbStore()
Method Detail

configPath

public java.lang.String configPath()
Specified by:
configPath in interface LeveldbStore

receive

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Description copied from interface: Actor
This defines the initial actor behavior, it must return a partial function with the actor logic.

Specified by:
receive in interface Actor
Returns:
(undocumented)