From 3db7cf9ba5fbb3686e0d183dbff40b8d985e140a Mon Sep 17 00:00:00 2001
From: Francisco Lopez-Sancho <franciscolopezsancho@gmail.com>
Date: Thu, 18 Nov 2021 08:23:23 +0000
Subject: [PATCH] fix: JavaSerializationException on
 akka.persistence.journal.Tagged with inmem (#30900)

JavaSerializationException on akka.persistence.journal.Tagged
for test with `akka.persistence.journal.inmem` plugin
---
 .../scala/akka/persistence/journal/inmem/InmemJournal.scala | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/akka-persistence/src/main/scala/akka/persistence/journal/inmem/InmemJournal.scala b/akka-persistence/src/main/scala/akka/persistence/journal/inmem/InmemJournal.scala
index 9ab1ac0951..43963ee4d9 100644
--- a/akka-persistence/src/main/scala/akka/persistence/journal/inmem/InmemJournal.scala
+++ b/akka-persistence/src/main/scala/akka/persistence/journal/inmem/InmemJournal.scala
@@ -73,7 +73,11 @@ object InmemJournal {
   override def asyncWriteMessages(messages: immutable.Seq[AtomicWrite]): Future[immutable.Seq[Try[Unit]]] = {
     try {
       for (w <- messages; p <- w.payload) {
-        verifySerialization(p.payload)
+        val payload = p.payload match {
+          case Tagged(payload, _) => payload
+          case _                  => p.payload
+        }
+        verifySerialization(payload)
         add(p)
         eventStream.publish(InmemJournal.Write(p.payload, p.persistenceId, p.sequenceNr))
       }