diff --git a/akka-persistence-tck/src/main/scala/akka/persistence/journal/JournalSpec.scala b/akka-persistence-tck/src/main/scala/akka/persistence/journal/JournalSpec.scala index 8bb124a4cf..c60562ac69 100644 --- a/akka-persistence-tck/src/main/scala/akka/persistence/journal/JournalSpec.scala +++ b/akka-persistence-tck/src/main/scala/akka/persistence/journal/JournalSpec.scala @@ -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)) } } diff --git a/akka-persistence-tck/src/test/scala/akka/persistence/journal/leveldb/LeveldbJournalNoAtomicPersistMultipleEventsSpec.scala b/akka-persistence-tck/src/test/scala/akka/persistence/journal/leveldb/LeveldbJournalNoAtomicPersistMultipleEventsSpec.scala new file mode 100644 index 0000000000..3e04471ce5 --- /dev/null +++ b/akka-persistence-tck/src/test/scala/akka/persistence/journal/leveldb/LeveldbJournalNoAtomicPersistMultipleEventsSpec.scala @@ -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 +} +