fix: compatible legacy tag read #673

akka · Sep 10, 2023 · f66aeb1 · f66aeb1
1 parent 6ed6098
commit f66aeb1
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]])