From 1b5d7e60f654eecd313dbfdc87ca75b3dc0a0aec Mon Sep 17 00:00:00 2001 From: AndyChen Date: Sun, 10 Sep 2023 16:02:00 +0800 Subject: [PATCH] fix: compatible legacy tag read #673 --- .../akka/persistence/jdbc/migrator/JournalMigrator.scala | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/migrator/src/main/scala/akka/persistence/jdbc/migrator/JournalMigrator.scala b/migrator/src/main/scala/akka/persistence/jdbc/migrator/JournalMigrator.scala index 59243358a..605f0e491 100644 --- a/migrator/src/main/scala/akka/persistence/jdbc/migrator/JournalMigrator.scala +++ b/migrator/src/main/scala/akka/persistence/jdbc/migrator/JournalMigrator.scala @@ -141,7 +141,11 @@ final case class JournalMigrator(profile: JdbcProfile)(implicit system: ActorSys val tagInserts = newJournalQueries.TagTable ++= tags .map(tag => - TagRow(None, Some(journalSerializedRow.persistenceId), Some(journalSerializedRow.sequenceNumber), tag)) + TagRow( + Some(journalSerializedRow.ordering), // legacy tag key enabled by default. + Some(journalSerializedRow.persistenceId), + Some(journalSerializedRow.sequenceNumber), + tag)) .toSeq journalInsert.flatMap(_ => tagInserts.asInstanceOf[DBIO[Unit]])