raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

=per #3739 Fix broken Javadoc generation

Browse source 
- caused by field named 'native' in LevelDBJournal
This commit is contained in:
Martin Krasser 2013-11-21 12:58:14 +01:00
parent 524addd404
commit 5f9355a778
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-persistence/src/main/scala/akka/persistence/journal/leveldb/LeveldbJournal.scala
View file

@ -22,7 +22,7 @@ import akka.serialization.SerializationExtension
*/
private[leveldb] class LeveldbJournal extends SyncWriteJournal with LeveldbIdMapping with LeveldbReplay {
val config = context.system.settings.config.getConfig("akka.persistence.journal.leveldb")
val native = config.getBoolean("native")
val nativeLeveldb = config.getBoolean("native")
val leveldbOptions = new Options().createIfMissing(true)
val leveldbReadOptions = new ReadOptions().verifyChecksums(config.getBoolean("checksum"))
@ -31,7 +31,7 @@ private[leveldb] class LeveldbJournal extends SyncWriteJournal with LeveldbIdMap
var leveldb: DB = _
def leveldbFactory =
if (native) org.fusesource.leveldbjni.JniDBFactory.factory
if (nativeLeveldb) org.fusesource.leveldbjni.JniDBFactory.factory
else org.iq80.leveldb.impl.Iq80DBFactory.factory
// TODO: support migration of processor and channel ids
@ -86,7 +86,7 @@ private[leveldb] class LeveldbJournal extends SyncWriteJournal with LeveldbIdMap
}
override def preStart() {
leveldb = leveldbFactory.open(leveldbDir, if (native) leveldbOptions else leveldbOptions.compressionType(CompressionType.NONE))
leveldb = leveldbFactory.open(leveldbDir, if (nativeLeveldb) leveldbOptions else leveldbOptions.compressionType(CompressionType.NONE))
super.preStart()
}