fix: compatible legacy tag read akka#673

Roiocam · Oct 8, 2023 · 71536ce · 71536ce
1 parent 4523e57
commit 71536ce
Showing 1 changed file with 5 additions and 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
@@ -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]])