This is an automated email from the ASF dual-hosted git repository.
mdedetrich pushed a commit to branch main
in repository
https://gitbox.apache.org/repos/asf/incubator-pekko-persistence-jdbc.git
The following commit(s) were added to refs/heads/main by this push:
new 38d1f0b Remove deprecated multiarg infix tuple syntax
38d1f0b is described below
commit 38d1f0b256ae84f9b8210b33c3f3712dabc02336
Author: Matthew de Detrich <[email protected]>
AuthorDate: Sun May 21 12:00:16 2023 +0200
Remove deprecated multiarg infix tuple syntax
---
.../org/apache/pekko/persistence/jdbc/journal/dao/JournalTables.scala | 4 ++--
.../pekko/persistence/jdbc/journal/dao/legacy/JournalTables.scala | 2 +-
.../apache/pekko/persistence/jdbc/snapshot/dao/SnapshotTables.scala | 2 +-
.../pekko/persistence/jdbc/snapshot/dao/legacy/SnapshotTables.scala | 2 +-
4 files changed, 5 insertions(+), 5 deletions(-)
diff --git
a/core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/JournalTables.scala
b/core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/JournalTables.scala
index 80ba1ca..1a296e2 100644
---
a/core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/JournalTables.scala
+++
b/core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/JournalTables.scala
@@ -74,7 +74,7 @@ trait JournalTables {
eventSerManifest,
metaPayload,
metaSerId,
- metaSerManifest) <> (JournalPekkoSerializationRow.tupled,
JournalPekkoSerializationRow.unapply)
+ metaSerManifest).<>(JournalPekkoSerializationRow.tupled,
JournalPekkoSerializationRow.unapply)
val ordering: Rep[Long] =
column[Long](journalTableCfg.columnNames.ordering, O.AutoInc)
val persistenceId: Rep[String] =
@@ -101,7 +101,7 @@ trait JournalTables {
lazy val JournalTable = new TableQuery(tag => new JournalEvents(tag))
class EventTags(_tableTag: Tag) extends Table[TagRow](_tableTag,
tagTableCfg.schemaName, tagTableCfg.tableName) {
- override def * = (eventId, tag) <> (TagRow.tupled, TagRow.unapply)
+ override def * = (eventId, tag).<>(TagRow.tupled, TagRow.unapply)
val eventId: Rep[Long] = column[Long](tagTableCfg.columnNames.eventId)
val tag: Rep[String] = column[String](tagTableCfg.columnNames.tag)
diff --git
a/core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/JournalTables.scala
b/core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/JournalTables.scala
index 96f25d6..5beef50 100644
---
a/core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/JournalTables.scala
+++
b/core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/JournalTables.scala
@@ -28,7 +28,7 @@ trait JournalTables {
_tableTag,
_schemaName = journalTableCfg.schemaName,
_tableName = journalTableCfg.tableName) {
- def * = (ordering, deleted, persistenceId, sequenceNumber, message, tags)
<> (JournalRow.tupled, JournalRow.unapply)
+ def * = (ordering, deleted, persistenceId, sequenceNumber, message,
tags).<>(JournalRow.tupled, JournalRow.unapply)
val ordering: Rep[Long] =
column[Long](journalTableCfg.columnNames.ordering, O.AutoInc)
val persistenceId: Rep[String] =
diff --git
a/core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/SnapshotTables.scala
b/core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/SnapshotTables.scala
index 75bbd79..78538d9 100644
---
a/core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/SnapshotTables.scala
+++
b/core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/SnapshotTables.scala
@@ -53,7 +53,7 @@ trait SnapshotTables {
snapshotPayload,
metaSerId,
metaSerManifest,
- metaPayload) <> (SnapshotRow.tupled, SnapshotRow.unapply)
+ metaPayload).<>(SnapshotRow.tupled, SnapshotRow.unapply)
val persistenceId: Rep[String] =
column[String](snapshotTableCfg.columnNames.persistenceId, O.Length(255,
varying = true))
diff --git
a/core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/legacy/SnapshotTables.scala
b/core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/legacy/SnapshotTables.scala
index e959c76..2ae6ebf 100644
---
a/core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/legacy/SnapshotTables.scala
+++
b/core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/legacy/SnapshotTables.scala
@@ -41,7 +41,7 @@ trait SnapshotTables {
_tableTag,
_schemaName = snapshotTableCfg.schemaName,
_tableName = snapshotTableCfg.tableName) {
- def * = (persistenceId, sequenceNumber, created, snapshot) <>
(SnapshotRow.tupled, SnapshotRow.unapply)
+ def * = (persistenceId, sequenceNumber, created,
snapshot).<>(SnapshotRow.tupled, SnapshotRow.unapply)
val persistenceId: Rep[String] =
column[String](snapshotTableCfg.columnNames.persistenceId, O.Length(255,
varying = true))
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
