From 85695240c4d94d10e02ef7e8418befacb0f51aa1 Mon Sep 17 00:00:00 2001 From: Mario Siegenthaler Date: Tue, 26 Nov 2019 15:49:19 +0100 Subject: [PATCH] feat: unwrap Tagged from akka persistence --- .../main/scala/akka/persistence/pg/journal/JournalStore.scala | 2 ++ 1 file changed, 2 insertions(+) diff --git a/modules/akka-persistence-pg/src/main/scala/akka/persistence/pg/journal/JournalStore.scala b/modules/akka-persistence-pg/src/main/scala/akka/persistence/pg/journal/JournalStore.scala index 753754b..d62c917 100644 --- a/modules/akka-persistence-pg/src/main/scala/akka/persistence/pg/journal/JournalStore.scala +++ b/modules/akka-persistence-pg/src/main/scala/akka/persistence/pg/journal/JournalStore.scala @@ -9,6 +9,7 @@ import akka.persistence.pg.{EventTag, JsonString, PgConfig, PgExtension} import akka.serialization.{Serialization, Serializers} import scala.util.Try +import akka.persistence.journal.Tagged /** * The journal/event store: it stores persistent messages. @@ -64,6 +65,7 @@ trait JournalStore extends JournalTable { messages map { message => val event = message.payload match { case w: EventWrapper[_] => w.event + case w: Tagged => w.payload case _ => message.payload } val tags: Map[String, String] = eventTagger.tags(message.payload)