Skip to content

Commit

Permalink
fix: compatible legacy tag read akka#673
Browse files Browse the repository at this point in the history
  • Loading branch information
Roiocam committed Sep 10, 2023
1 parent 6ed6098 commit f66aeb1
Showing 1 changed file with 5 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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]])
Expand Down

0 comments on commit f66aeb1

Please sign in to comment.