Merge pull request #18669 from nilsga/tck-double-wrap-fix
=per #18646 Remove double wrapping of PersistentRepr in JournalSpec
This commit is contained in:
commit
8ebe83a630
2 changed files with 19 additions and 1 deletions
|
|
@ -71,7 +71,7 @@ abstract class JournalSpec(config: Config) extends PluginSpec(config) {
|
|||
}
|
||||
} else {
|
||||
(fromSnr to toSnr).map { i ⇒
|
||||
AtomicWrite(PersistentRepr(persistentRepr(i)))
|
||||
AtomicWrite(persistentRepr(i))
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -0,0 +1,18 @@
|
|||
package akka.persistence.journal.leveldb
|
||||
|
||||
import akka.persistence.journal.JournalSpec
|
||||
import akka.persistence.{ PersistenceSpec, PluginCleanup }
|
||||
|
||||
class LeveldbJournalNoAtomicPersistMultipleEventsSpec extends JournalSpec(
|
||||
config = PersistenceSpec.config(
|
||||
"leveldb",
|
||||
"LeveldbJournalNoAtomicPersistMultipleEventsSpec",
|
||||
extraConfig = Some("akka.persistence.journal.leveldb.native = off")))
|
||||
with PluginCleanup {
|
||||
|
||||
/**
|
||||
* Setting to false to test the single message atomic write behaviour of JournalSpec
|
||||
*/
|
||||
override def supportsAtomicPersistAllOfSeveralEvents = false
|
||||
}
|
||||
|
||||
Loading…
Add table
Add a link
Reference in a new issue