Package akka.persistence.journal.leveldb
Class LeveldbJournal
- java.lang.Object
-
- akka.persistence.journal.leveldb.LeveldbJournal
-
- All Implemented Interfaces:
Actor
,ActorLogging
,AsyncRecovery
,AsyncWriteJournal
,CompactionSegmentManagement
,LeveldbCompaction
,LeveldbIdMapping
,LeveldbRecovery
,LeveldbStore
,WriteJournalBase
public class LeveldbJournal extends java.lang.Object implements AsyncWriteJournal, LeveldbStore
Deprecated.Use another journal implementation. Since 2.6.15.INTERNAL API.Journal backed by a local LevelDB store. For production use.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
LeveldbJournal.CurrentPersistenceIds
Deprecated.static class
LeveldbJournal.CurrentPersistenceIds$
Deprecated.static class
LeveldbJournal.EventAppended
Deprecated.static class
LeveldbJournal.EventAppended$
Deprecated.static class
LeveldbJournal.PersistenceIdAdded
Deprecated.static class
LeveldbJournal.PersistenceIdAdded$
Deprecated.static class
LeveldbJournal.ReplayedTaggedMessage
Deprecated.static class
LeveldbJournal.ReplayedTaggedMessage$
Deprecated.static class
LeveldbJournal.ReplayTaggedMessages
Deprecated.fromSequenceNr
is exclusivetoSequenceNr
is inclusivestatic class
LeveldbJournal.ReplayTaggedMessages$
Deprecated.static class
LeveldbJournal.SubscribeAllPersistenceIds$
Deprecated.Subscribe thesender
to current and new persistenceIds.static class
LeveldbJournal.SubscribePersistenceId
Deprecated.Subscribe thesender
to changes (appended events) for a specificpersistenceId
.static class
LeveldbJournal.SubscribePersistenceId$
Deprecated.static class
LeveldbJournal.SubscribeTag
Deprecated.Subscribe thesender
to changes (appended events) for a specifictag
.static class
LeveldbJournal.SubscribeTag$
Deprecated.static interface
LeveldbJournal.SubscriptionCommand
Deprecated.static class
LeveldbJournal.TaggedEventAppended
Deprecated.static class
LeveldbJournal.TaggedEventAppended$
Deprecated.-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
Nested classes/interfaces inherited from interface akka.persistence.journal.AsyncWriteJournal
AsyncWriteJournal.Desequenced, AsyncWriteJournal.Desequenced$, AsyncWriteJournal.Resequencer
-
Nested classes/interfaces inherited from interface akka.persistence.journal.leveldb.LeveldbCompaction
LeveldbCompaction.TryCompactLeveldb, LeveldbCompaction.TryCompactLeveldb$
-
-
Constructor Summary
Constructors Constructor Description LeveldbJournal()
Deprecated.LeveldbJournal(com.typesafe.config.Config cfg)
Deprecated.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description protected void
akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
Deprecated.Scala API: Stores the context for this actor, including self, and sender.protected void
akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
Deprecated.The 'self' field holds the ActorRef for this actor.protected void
akka$persistence$journal$AsyncWriteJournal$_setter_$receiveWriteJournal_$eq(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> x$1)
Deprecated.protected void
akka$persistence$journal$leveldb$LeveldbStore$_setter_$compactionIntervals_$eq(scala.collection.immutable.Map<java.lang.String,java.lang.Object> x$1)
Deprecated.protected void
akka$persistence$journal$leveldb$LeveldbStore$_setter_$config_$eq(com.typesafe.config.Config x$1)
Deprecated.protected void
akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbDir_$eq(java.io.File x$1)
Deprecated.protected void
akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbOptions_$eq(org.iq80.leveldb.Options x$1)
Deprecated.protected void
akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbWriteOptions_$eq(org.iq80.leveldb.WriteOptions x$1)
Deprecated.protected void
akka$persistence$journal$leveldb$LeveldbStore$_setter_$nativeLeveldb_$eq(boolean x$1)
Deprecated.protected void
akka$persistence$journal$leveldb$LeveldbStore$_setter_$serialization_$eq(Serialization x$1)
Deprecated.protected void
akka$persistence$journal$WriteJournalBase$_setter_$persistence_$eq(Persistence x$1)
Deprecated.scala.collection.immutable.Map<java.lang.String,java.lang.Object>
compactionIntervals()
Deprecated.com.typesafe.config.Config
config()
Deprecated.ActorContext
context()
Deprecated.Scala API: Stores the context for this actor, including self, and sender.org.iq80.leveldb.DB
leveldb()
Deprecated.void
leveldb_$eq(org.iq80.leveldb.DB x$1)
Deprecated.java.io.File
leveldbDir()
Deprecated.org.iq80.leveldb.Options
leveldbOptions()
Deprecated.org.iq80.leveldb.WriteOptions
leveldbWriteOptions()
Deprecated.boolean
nativeLeveldb()
Deprecated.Persistence
persistence()
Deprecated.com.typesafe.config.Config
prepareConfig()
Deprecated.scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receivePluginInternal()
Deprecated.Plugin APIscala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receiveWriteJournal()
Deprecated.ActorRef
self()
Deprecated.The 'self' field holds the ActorRef for this actor.Serialization
serialization()
Deprecated.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, preRestart, sender, supervisorStrategy, unhandled
-
Methods inherited from interface akka.actor.ActorLogging
_log_$eq, log
-
Methods inherited from interface akka.persistence.journal.AsyncWriteJournal
asyncDeleteMessagesTo, asyncWriteMessages, isReplayFilterEnabled, receive, resequencerCounter_$eq
-
Methods inherited from interface akka.persistence.journal.leveldb.CompactionSegmentManagement
compactionInterval, compactionLimit, compactionSegment, isCompactionEnabled, isCompactionRequired, latestCompactionSegment, latestCompactionSegments_$eq, mustCompact, updateCompactionSegment
-
Methods inherited from interface akka.persistence.journal.leveldb.LeveldbCompaction
receiveCompactionInternal, tryCompactOnDelete
-
Methods inherited from interface akka.persistence.journal.leveldb.LeveldbIdMapping
allPersistenceIds, idMap_$eq, isNewPersistenceId, numericId, readIdMap, readIdMap, writeIdMapping
-
Methods inherited from interface akka.persistence.journal.leveldb.LeveldbRecovery
asyncReadHighestSequenceNr, asyncReplayMessages, asyncReplayTaggedMessages, readHighestSequenceNr, replayMessages, replayTaggedMessages
-
Methods inherited from interface akka.persistence.journal.leveldb.LeveldbStore
addAllPersistenceIdsSubscriber, addPersistenceIdSubscriber, addTagSubscriber, addToMessageBatch, allPersistenceIdsSubscribers_$eq, asyncDeleteMessagesTo, asyncWriteMessages, hasAllPersistenceIdsSubscribers, hasPersistenceIdSubscribers, hasTagSubscribers, leveldbFactory, leveldbReadOptions, leveldbSnapshot, newPersistenceIdAdded, nextTagSequenceNr, notifyPersistenceIdChange, notifyTagChange, persistentFromBytes, persistentToBytes, postStop, preStart, removeSubscriber, super$postStop, super$preStart, tagAsPersistenceId, tagNumericId, tagSequenceNr_$eq, withBatch, withIterator
-
Methods inherited from interface akka.persistence.journal.WriteJournalBase
adaptFromJournal, adaptToJournal, preparePersistentBatch
-
-
-
-
Method Detail
-
config
public com.typesafe.config.Config config()
Deprecated.- Specified by:
config
in interfaceLeveldbStore
-
nativeLeveldb
public boolean nativeLeveldb()
Deprecated.- Specified by:
nativeLeveldb
in interfaceLeveldbStore
-
leveldbOptions
public org.iq80.leveldb.Options leveldbOptions()
Deprecated.- Specified by:
leveldbOptions
in interfaceLeveldbStore
-
leveldbWriteOptions
public org.iq80.leveldb.WriteOptions leveldbWriteOptions()
Deprecated.- Specified by:
leveldbWriteOptions
in interfaceLeveldbStore
-
leveldbDir
public java.io.File leveldbDir()
Deprecated.- Specified by:
leveldbDir
in interfaceLeveldbStore
-
leveldb
public org.iq80.leveldb.DB leveldb()
Deprecated.- Specified by:
leveldb
in interfaceLeveldbStore
-
leveldb_$eq
public void leveldb_$eq(org.iq80.leveldb.DB x$1)
Deprecated.- Specified by:
leveldb_$eq
in interfaceLeveldbStore
-
compactionIntervals
public scala.collection.immutable.Map<java.lang.String,java.lang.Object> compactionIntervals()
Deprecated.- Specified by:
compactionIntervals
in interfaceCompactionSegmentManagement
- Specified by:
compactionIntervals
in interfaceLeveldbStore
-
serialization
public Serialization serialization()
Deprecated.- Specified by:
serialization
in interfaceLeveldbStore
-
akka$persistence$journal$leveldb$LeveldbStore$_setter_$config_$eq
protected void akka$persistence$journal$leveldb$LeveldbStore$_setter_$config_$eq(com.typesafe.config.Config x$1)
Deprecated.- Specified by:
akka$persistence$journal$leveldb$LeveldbStore$_setter_$config_$eq
in interfaceLeveldbStore
-
akka$persistence$journal$leveldb$LeveldbStore$_setter_$nativeLeveldb_$eq
protected void akka$persistence$journal$leveldb$LeveldbStore$_setter_$nativeLeveldb_$eq(boolean x$1)
Deprecated.- Specified by:
akka$persistence$journal$leveldb$LeveldbStore$_setter_$nativeLeveldb_$eq
in interfaceLeveldbStore
-
akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbOptions_$eq
protected void akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbOptions_$eq(org.iq80.leveldb.Options x$1)
Deprecated.- Specified by:
akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbOptions_$eq
in interfaceLeveldbStore
-
akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbWriteOptions_$eq
protected void akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbWriteOptions_$eq(org.iq80.leveldb.WriteOptions x$1)
Deprecated.- Specified by:
akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbWriteOptions_$eq
in interfaceLeveldbStore
-
akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbDir_$eq
protected void akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbDir_$eq(java.io.File x$1)
Deprecated.- Specified by:
akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbDir_$eq
in interfaceLeveldbStore
-
akka$persistence$journal$leveldb$LeveldbStore$_setter_$compactionIntervals_$eq
protected void akka$persistence$journal$leveldb$LeveldbStore$_setter_$compactionIntervals_$eq(scala.collection.immutable.Map<java.lang.String,java.lang.Object> x$1)
Deprecated.- Specified by:
akka$persistence$journal$leveldb$LeveldbStore$_setter_$compactionIntervals_$eq
in interfaceLeveldbStore
-
akka$persistence$journal$leveldb$LeveldbStore$_setter_$serialization_$eq
protected void akka$persistence$journal$leveldb$LeveldbStore$_setter_$serialization_$eq(Serialization x$1)
Deprecated.- Specified by:
akka$persistence$journal$leveldb$LeveldbStore$_setter_$serialization_$eq
in interfaceLeveldbStore
-
receiveWriteJournal
public final scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveWriteJournal()
Deprecated.- Specified by:
receiveWriteJournal
in interfaceAsyncWriteJournal
-
akka$persistence$journal$AsyncWriteJournal$_setter_$receiveWriteJournal_$eq
protected final void akka$persistence$journal$AsyncWriteJournal$_setter_$receiveWriteJournal_$eq(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> x$1)
Deprecated.- Specified by:
akka$persistence$journal$AsyncWriteJournal$_setter_$receiveWriteJournal_$eq
in interfaceAsyncWriteJournal
-
persistence
public Persistence persistence()
Deprecated.- Specified by:
persistence
in interfaceWriteJournalBase
-
akka$persistence$journal$WriteJournalBase$_setter_$persistence_$eq
protected void akka$persistence$journal$WriteJournalBase$_setter_$persistence_$eq(Persistence x$1)
Deprecated.- Specified by:
akka$persistence$journal$WriteJournalBase$_setter_$persistence_$eq
in interfaceWriteJournalBase
-
context
public ActorContext context()
Deprecated.Description copied from interface:Actor
Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such asforward
.WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
ActorContext
is the Scala API.getContext
returns aAbstractActor.ActorContext
, which is the Java API of the actor context.
-
self
public final ActorRef self()
Deprecated.Description copied from interface:Actor
The 'self' field holds the ActorRef for this actor. Can be used to send messages to itself:self ! message
-
akka$actor$Actor$_setter_$context_$eq
protected void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
Deprecated.Description copied from interface:Actor
Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such asforward
.WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
ActorContext
is the Scala API.getContext
returns aAbstractActor.ActorContext
, which is the Java API of the actor context.- Specified by:
akka$actor$Actor$_setter_$context_$eq
in interfaceActor
-
akka$actor$Actor$_setter_$self_$eq
protected final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
Deprecated.Description copied from interface:Actor
The 'self' field holds the ActorRef for this actor. Can be used to send messages to itself:self ! message
- Specified by:
akka$actor$Actor$_setter_$self_$eq
in interfaceActor
-
prepareConfig
public com.typesafe.config.Config prepareConfig()
Deprecated.- Specified by:
prepareConfig
in interfaceLeveldbStore
-
receivePluginInternal
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receivePluginInternal()
Deprecated.Description copied from interface:AsyncWriteJournal
Plugin APIAllows plugin implementers to use
f pipeTo self
and handle additional messages for implementing advanced features- Specified by:
receivePluginInternal
in interfaceAsyncWriteJournal
-
-