Use journal_persistence_ids for maxJournalSequenceQuery

SwissBorg · Oct 13, 2021 · ec8dabf · ec8dabf
1 parent 33e9cb2
commit ec8dabf
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/core/src/main/scala/akka/persistence/postgres/query/dao/ReadJournalQueries.scala b/core/src/main/scala/akka/persistence/postgres/query/dao/ReadJournalQueries.scala
@@ -65,6 +65,6 @@ class ReadJournalQueries(val readJournalConfig: ReadJournalConfig) {
   val orderingByOrdering = Compiled(_journalSequenceQuery _)
 
   val maxOrdering = Compiled {
-    journalTable.map(_.ordering).max.getOrElse(0L)
+    journalPersistenceIdsTable.map(_.maxOrdering).max.getOrElse(0L)
   }
 }
diff --git a/core/src/test/scala/akka/persistence/postgres/query/dao/ReadJournalQueriesTest.scala b/core/src/test/scala/akka/persistence/postgres/query/dao/ReadJournalQueriesTest.scala
@@ -30,7 +30,7 @@ class ReadJournalQueriesTest extends BaseQueryTest {
   }
 
   it should "create SQL query for maxJournalSequenceQuery" in withReadJournalQueries { queries =>
-    queries.maxOrdering shouldBeSQL """select max("ordering") from "journal""""
+    queries.maxOrdering shouldBeSQL """select max("max_ordering") from "journal_persistence_ids""""
   }
 
   private def withReadJournalQueries(f: ReadJournalQueries => Unit): Unit = {