Reformat with scalafmt 3.8.2

Executed command: scalafmt --non-interactive
apache · Jun 16, 2024 · 8de5f86 · 8de5f86
1 parent f4cdf3e
commit 8de5f86
Show file tree

Hide file tree

Showing 5 changed files with 12 additions and 22 deletions.
diff --git a/core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/JdbcAsyncWriteJournal.scala b/core/src/main/scala/org/apache/pekko/persistence/jdbc/journal/JdbcAsyncWriteJournal.scala
@@ -66,11 +66,8 @@ class JdbcAsyncWriteJournal(config: Config) extends AsyncWriteJournal {
     val fqcn = journalConfig.pluginConfig.dao
     val profile: JdbcProfile = slickDb.profile
     val args = Seq(
-      (classOf[Database], db),
-      (classOf[JdbcProfile], profile),
-      (classOf[JournalConfig], journalConfig),
-      (classOf[Serialization], SerializationExtension(system)),
-      (classOf[ExecutionContext], ec),
+      (classOf[Database], db), (classOf[JdbcProfile], profile), (classOf[JournalConfig], journalConfig),
+      (classOf[Serialization], SerializationExtension(system)), (classOf[ExecutionContext], ec),
       (classOf[Materializer], mat))
     system.asInstanceOf[ExtendedActorSystem].dynamicAccess.createInstanceFor[JournalDao](fqcn, args) match {
       case Success(dao)   => dao

diff --git a/core/src/main/scala/org/apache/pekko/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala b/core/src/main/scala/org/apache/pekko/persistence/jdbc/query/scaladsl/JdbcReadJournal.scala
@@ -77,11 +77,8 @@ class JdbcReadJournal(config: Config, configPath: String)(implicit val system: E
     val fqcn = readJournalConfig.pluginConfig.dao
     val profile: JdbcProfile = slickDb.profile
     val args = Seq(
-      (classOf[Database], db),
-      (classOf[JdbcProfile], profile),
-      (classOf[ReadJournalConfig], readJournalConfig),
-      (classOf[Serialization], SerializationExtension(system)),
-      (classOf[ExecutionContext], ec),
+      (classOf[Database], db), (classOf[JdbcProfile], profile), (classOf[ReadJournalConfig], readJournalConfig),
+      (classOf[Serialization], SerializationExtension(system)), (classOf[ExecutionContext], ec),
       (classOf[Materializer], mat))
     system.dynamicAccess.createInstanceFor[ReadJournalDao](fqcn, args) match {
       case Success(dao)   => dao

diff --git a/core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/JdbcSnapshotStore.scala b/core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/JdbcSnapshotStore.scala
@@ -53,11 +53,8 @@ class JdbcSnapshotStore(config: Config) extends SnapshotStore {
     val fqcn = snapshotConfig.pluginConfig.dao
     val profile: JdbcProfile = slickDb.profile
     val args = Seq(
-      (classOf[Database], db),
-      (classOf[JdbcProfile], profile),
-      (classOf[SnapshotConfig], snapshotConfig),
-      (classOf[Serialization], SerializationExtension(system)),
-      (classOf[ExecutionContext], ec),
+      (classOf[Database], db), (classOf[JdbcProfile], profile), (classOf[SnapshotConfig], snapshotConfig),
+      (classOf[Serialization], SerializationExtension(system)), (classOf[ExecutionContext], ec),
       (classOf[Materializer], mat))
     system.asInstanceOf[ExtendedActorSystem].dynamicAccess.createInstanceFor[SnapshotDao](fqcn, args) match {
       case Success(dao)   => dao

diff --git a/core/src/main/scala/org/apache/pekko/persistence/jdbc/state/SequenceNextValUpdater.scala b/core/src/main/scala/org/apache/pekko/persistence/jdbc/state/SequenceNextValUpdater.scala
@@ -57,7 +57,8 @@ import slick.sql.SqlStreamingAction
   import profile.api._
 
   def getSequenceNextValueExpr() =
-    sql"""SELECT nextval(pg_get_serial_sequence('#${durableStateTableCfg.tableName}', '#${durableStateTableCfg.columnNames.globalOffset}'))""".as[
+    sql"""SELECT nextval(pg_get_serial_sequence('#${durableStateTableCfg.tableName}', '#${durableStateTableCfg
+        .columnNames.globalOffset}'))""".as[
       String]
 }
 
@@ -84,6 +85,7 @@ import slick.sql.SqlStreamingAction
   import profile.api._
 
   def getSequenceNextValueExpr() =
-    sql"""SELECT #${durableStateTableCfg.tableName}__#${durableStateTableCfg.columnNames.globalOffset}_SEQ.nextval FROM DUAL""".as[
+    sql"""SELECT #${durableStateTableCfg.tableName}__#${durableStateTableCfg.columnNames
+        .globalOffset}_SEQ.nextval FROM DUAL""".as[
       String]
 }
diff --git a/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/QueryTestSpec.scala b/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/QueryTestSpec.scala
@@ -343,11 +343,8 @@ abstract class QueryTestSpec(config: String, configOverrides: Map[String, Config
   def withDao(f: JournalDao => Unit)(implicit system: ActorSystem, ec: ExecutionContext, mat: Materializer): Unit = {
     val fqcn: String = journalConfig.pluginConfig.dao
     val args: immutable.Seq[(Class[_], AnyRef)] = immutable.Seq(
-      (classOf[Database], db),
-      (classOf[JdbcProfile], profile),
-      (classOf[JournalConfig], journalConfig),
-      (classOf[Serialization], SerializationExtension(system)),
-      (classOf[ExecutionContext], ec),
+      (classOf[Database], db), (classOf[JdbcProfile], profile), (classOf[JournalConfig], journalConfig),
+      (classOf[Serialization], SerializationExtension(system)), (classOf[ExecutionContext], ec),
       (classOf[Materializer], mat))
     val journalDao: JournalDao =
       system.asInstanceOf[ExtendedActorSystem].dynamicAccess.createInstanceFor[JournalDao](fqcn, args) match {