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

=per #3797 Harden file deletions in persistence tests

Browse source
This commit is contained in:
Patrik Nordwall 2013-12-20 12:40:54 +01:00
parent b8c7d7badd
commit e94fc68f2f
11 changed files with 37 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

18
akka-persistence/src/test/scala/akka/persistence/journal/leveldb/SharedLeveldbJournalSpec.scala
View file

@ -20,9 +20,9 @@ object SharedLeveldbJournalSpec {
persistence {
journal {
plugin = "akka.persistence.journal.leveldb-shared"
leveldb-shared.store.dir = target/shared-journal
leveldb-shared.store.dir = target/journal-SharedLeveldbJournalSpec
}
snapshot-store.local.dir = target/snapshot-store
snapshot-store.local.dir = target/snapshots-SharedLeveldbJournalSpec
}
remote {
enabled-transports = ["akka.remote.netty.tcp"]
@ -63,11 +63,19 @@ object SharedLeveldbJournalSpec {
class SharedLeveldbJournalSpec extends AkkaSpec(SharedLeveldbJournalSpec.config) with Cleanup {
import SharedLeveldbJournalSpec._
val storeSystem = ActorSystem("store", ConfigFactory.parseString(SharedLeveldbJournalSpec.config))
val processorASystem = ActorSystem("processorA", ConfigFactory.parseString(SharedLeveldbJournalSpec.config))
val processorBSystem = ActorSystem("processorB", ConfigFactory.parseString(SharedLeveldbJournalSpec.config))
override protected def afterTermination() {
shutdown(storeSystem)
shutdown(processorASystem)
shutdown(processorBSystem)
super.afterTermination()
}
"A LevelDB store" can {
"be shared by multiple actor systems" in {
val storeSystem = ActorSystem("store", ConfigFactory.parseString(SharedLeveldbJournalSpec.config))
val processorASystem = ActorSystem("processorA", ConfigFactory.parseString(SharedLeveldbJournalSpec.config))
val processorBSystem = ActorSystem("processorB", ConfigFactory.parseString(SharedLeveldbJournalSpec.config))
val processorAProbe = new TestProbe(processorASystem)
val processorBProbe = new TestProbe(processorBSystem)