Skip to content

Commit ed38da6

Browse files
committed
Remove unused artifacts and add comment on journal metadata migration table
1 parent 40ad1a9 commit ed38da6

File tree

3 files changed

+2
-2
lines changed

3 files changed

+2
-2
lines changed

core/src/main/scala/akka/persistence/postgres/journal/dao/BaseByteArrayJournalDao.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -139,7 +139,7 @@ trait BaseByteArrayJournalDao extends JournalDaoWithUpdates with BaseJournalDaoW
139139

140140
override def highestSequenceNr(persistenceId: String, fromSequenceNr: Long): Future[Long] =
141141
for {
142-
maybeHighestSeqNo <- db.run(queries.highestSequenceNrForPersistenceId(persistenceId).result) // .headOption)
142+
maybeHighestSeqNo <- db.run(queries.highestSequenceNrForPersistenceId(persistenceId).result)
143143
} yield maybeHighestSeqNo.getOrElse(0L)
144144

145145
override def messages(

core/src/main/scala/akka/persistence/postgres/journal/dao/JournalQueries.scala

-1
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,6 @@ class JournalQueries(
4949

5050
private def _highestSequenceNrForPersistenceId(persistenceId: Rep[String]) = {
5151
journalTable.filter(_.persistenceId === persistenceId).map(_.sequenceNumber).max
52-
// journalPersistenceIdsTable.filter(_.persistenceId === persistenceId).map(_.maxSequenceNumber).take(1)
5352
}
5453

5554
private def _highestMarkedSequenceNrForPersistenceId(persistenceId: Rep[String]): Rep[Option[Long]] =

scripts/migration-0.6.0/1-create-journal-persistence-ids-table.sql

+1
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
-- Depending on your use case consider partitioning this table.
12
DO $$
23
DECLARE
34
-- replace with appropriate values

0 commit comments

Comments
 (0)