From f3e13341c2c86b24196d4a70e75432adfca99ccf Mon Sep 17 00:00:00 2001
From: Nils-Helge Garli Hegvik <nilsga@gmail.com>
Date: Wed, 7 Oct 2015 23:13:07 +0200
Subject: [PATCH] =per #18646 Remove double wrapping of PersistentRepr in
 writeMessages

---
 .../akka/persistence/journal/JournalSpec.scala |  2 +-
 ...rnalNoAtomicPersistMultipleEventsSpec.scala | 18 ++++++++++++++++++
 2 files changed, 19 insertions(+), 1 deletion(-)
 create mode 100644 akka-persistence-tck/src/test/scala/akka/persistence/journal/leveldb/LeveldbJournalNoAtomicPersistMultipleEventsSpec.scala

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
+}
+