This is an automated email from the ASF dual-hosted git repository. fanningpj pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pekko-persistence-jdbc.git
commit 406007b351e84e977697d539d11fbeca26b5ee0c Author: Scala Steward <[email protected]> AuthorDate: Sat Jan 17 16:28:50 2026 +0000 Reformat with scalafmt 3.10.4 Executed command: scalafmt --non-interactive --- build.sbt | 15 +++++++++------ .../persistence/jdbc/state/DurableStateQueries.scala | 8 +------- .../jdbc/state/scaladsl/DurableStateSequenceActor.scala | 3 +-- .../persistence/jdbc/configuration/JNDIConfigTest.scala | 6 ++++-- .../jdbc/journal/dao/LimitWindowingStreamTest.scala | 7 +++---- .../dao/legacy/ByteArrayJournalSerializerTest.scala | 3 ++- .../persistence/jdbc/query/CurrentEventsByTagTest.scala | 3 ++- .../jdbc/query/JournalDaoStreamMessagesMemoryTest.scala | 7 +++---- .../persistence/jdbc/query/JournalSequenceActorTest.scala | 6 ++++-- .../pekko/persistence/jdbc/query/QueryTestSpec.scala | 6 ++++-- .../jdbc/state/scaladsl/JdbcDurableStateSpec.scala | 6 ++++-- .../jdbc/integration/AllPersistenceIdsTest.scala | 7 +------ .../integration/CurrentEventsByPersistenceIdTest.scala | 7 +------ .../jdbc/integration/CurrentEventsByTagTest.scala | 7 +------ ...urrentLastKnownSequenceNumberByPersistenceIdTest.scala | 6 +----- .../jdbc/integration/CurrentPersistenceIdsTest.scala | 7 +------ .../persistence/jdbc/integration/EventAdapterTest.scala | 7 +------ .../jdbc/integration/EventsByPersistenceIdTest.scala | 7 +------ .../persistence/jdbc/integration/EventsByTagTest.scala | 7 +------ .../jdbc/integration/HardDeleteQueryTest.scala | 7 +------ .../integration/JournalDaoStreamMessagesMemoryTest.scala | 7 +------ .../jdbc/integration/JournalSequenceActorTest.scala | 7 +------ .../jdbc/integration/LimitWindowingStreamTest.scala | 6 +----- .../integration/MariaDBDurableStateStorePluginSpec.scala | 3 +-- .../integration/MySQLDurableStateStorePluginSpec.scala | 3 +-- .../integration/PostgresDurableStateStorePluginSpec.scala | 3 +-- project/ProjectAutoPlugin.scala | 13 +++++++------ 27 files changed, 59 insertions(+), 115 deletions(-) diff --git a/build.sbt b/build.sbt index 2c3ab3a..758d2f1 100644 --- a/build.sbt +++ b/build.sbt @@ -43,10 +43,11 @@ lazy val core = project name := "pekko-persistence-jdbc", // Transitive dependency `scala-reflect` to avoid `NoClassDefFoundError`. // See: https://github.com/slick/slick/issues/2933 - libraryDependencies ++= (CrossVersion.partialVersion(scalaVersion.value) match { - case Some((2, _)) => Seq("org.scala-lang" % "scala-reflect" % scalaVersion.value) - case _ => Nil - }), + libraryDependencies ++= + (CrossVersion.partialVersion(scalaVersion.value) match { + case Some((2, _)) => Seq("org.scala-lang" % "scala-reflect" % scalaVersion.value) + case _ => Nil + }), libraryDependencies ++= Dependencies.Libraries, mimaReportSignatureProblems := true, mimaPreviousArtifacts := Set( @@ -105,8 +106,10 @@ lazy val docs = project // Pekko "extref.pekko.base_url" -> s"https://pekko.apache.org/docs/pekko/${PekkoCoreDependency.default.link}/%s";, "scaladoc.base_url" -> "https://pekko.apache.org/api/pekko-persistence-jdbc/current/";, - "scaladoc.org.apache.pekko.base_url" -> s"https://pekko.apache.org/api/pekko/${PekkoCoreDependency.default.link}/";, - "javadoc.org.apache.pekko.base_url" -> s"https://pekko.apache.org/japi/pekko/${PekkoCoreDependency.default.link}/";, + "scaladoc.org.apache.pekko.base_url" -> + s"https://pekko.apache.org/api/pekko/${PekkoCoreDependency.default.link}/";, + "javadoc.org.apache.pekko.base_url" -> + s"https://pekko.apache.org/japi/pekko/${PekkoCoreDependency.default.link}/";, "javadoc.org.apache.pekko.link_style" -> "direct", // Java "javadoc.base_url" -> "https://docs.oracle.com/javase/8/docs/api/";, diff --git a/core/src/main/scala/org/apache/pekko/persistence/jdbc/state/DurableStateQueries.scala b/core/src/main/scala/org/apache/pekko/persistence/jdbc/state/DurableStateQueries.scala index b434610..3346f47 100644 --- a/core/src/main/scala/org/apache/pekko/persistence/jdbc/state/DurableStateQueries.scala +++ b/core/src/main/scala/org/apache/pekko/persistence/jdbc/state/DurableStateQueries.scala @@ -20,13 +20,7 @@ import pekko.persistence.jdbc.config.DurableStateTableConfiguration import pekko.persistence.jdbc.db.MariaDBProfile import slick.jdbc.{ - H2Profile, - JdbcProfile, - MySQLProfile, - OracleProfile, - PostgresProfile, - SQLServerProfile, - SetParameter + H2Profile, JdbcProfile, MySQLProfile, OracleProfile, PostgresProfile, SQLServerProfile, SetParameter } /** diff --git a/core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/DurableStateSequenceActor.scala b/core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/DurableStateSequenceActor.scala index 1876145..4fd50fc 100644 --- a/core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/DurableStateSequenceActor.scala +++ b/core/src/main/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/DurableStateSequenceActor.scala @@ -241,8 +241,7 @@ import pekko.annotation.InternalApi if (revDiff <= 1) { (revChg, maxOffset, cacheMiss) } else { - val pidOffsets = - (e.offset until elem.offset).tail // e.offset and elem.offset are known to not be missing + val pidOffsets = (e.offset until elem.offset).tail // e.offset and elem.offset are known to not be missing val missingCount = math.min(pidOffsets.count(missingElems.contains), revDiff - 1) (revChg + missingCount, maxOffset, cacheMiss) } diff --git a/core/src/test/scala/org/apache/pekko/persistence/jdbc/configuration/JNDIConfigTest.scala b/core/src/test/scala/org/apache/pekko/persistence/jdbc/configuration/JNDIConfigTest.scala index a9c8f59..e2f5dde 100644 --- a/core/src/test/scala/org/apache/pekko/persistence/jdbc/configuration/JNDIConfigTest.scala +++ b/core/src/test/scala/org/apache/pekko/persistence/jdbc/configuration/JNDIConfigTest.scala @@ -21,7 +21,8 @@ import pekko.persistence.jdbc.SimpleSpec import pekko.persistence.jdbc.db.SlickExtension class JNDIConfigTest extends SimpleSpec { - "JNDI config" should "read the config and throw NoInitialContextException in case the JNDI resource is not available" in { + "JNDI config" should + "read the config and throw NoInitialContextException in case the JNDI resource is not available" in { withActorSystem("jndi-application.conf") { system => val jdbcJournalConfig = system.settings.config.getConfig("jdbc-journal") val slickExtension = SlickExtension(system) @@ -33,7 +34,8 @@ class JNDIConfigTest extends SimpleSpec { } } - "JNDI config for shared databases" should "read the config and throw NoInitialContextException in case the JNDI resource is not available" in { + "JNDI config for shared databases" should + "read the config and throw NoInitialContextException in case the JNDI resource is not available" in { withActorSystem("jndi-shared-db-application.conf") { system => val jdbcJournalConfig = system.settings.config.getConfig("jdbc-journal") val slickExtension = SlickExtension(system) diff --git a/core/src/test/scala/org/apache/pekko/persistence/jdbc/journal/dao/LimitWindowingStreamTest.scala b/core/src/test/scala/org/apache/pekko/persistence/jdbc/journal/dao/LimitWindowingStreamTest.scala index be2679f..d2f898e 100644 --- a/core/src/test/scala/org/apache/pekko/persistence/jdbc/journal/dao/LimitWindowingStreamTest.scala +++ b/core/src/test/scala/org/apache/pekko/persistence/jdbc/journal/dao/LimitWindowingStreamTest.scala @@ -64,10 +64,9 @@ abstract class LimitWindowingStreamTest(configFile: String) val end = i * eventsPerBatch val start = end - (eventsPerBatch - 1) log.info(s"batch $i - events from $start to $end") - val atomicWrites = - (start to end).map { j => - AtomicWrite(immutable.Seq(PersistentRepr(payload, j, persistenceId, writerUuid = writerUuid))) - } + val atomicWrites = (start to end).map { j => + AtomicWrite(immutable.Seq(PersistentRepr(payload, j, persistenceId, writerUuid = writerUuid))) + } dao.asyncWriteMessages(atomicWrites).map(_ => i) } .runWith(Sink.last) diff --git a/core/src/test/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/ByteArrayJournalSerializerTest.scala b/core/src/test/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/ByteArrayJournalSerializerTest.scala index 91f4724..23402c1 100644 --- a/core/src/test/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/ByteArrayJournalSerializerTest.scala +++ b/core/src/test/scala/org/apache/pekko/persistence/jdbc/journal/dao/legacy/ByteArrayJournalSerializerTest.scala @@ -35,7 +35,8 @@ class ByteArrayJournalSerializerTest extends SharedActorSystemTestSpec() { (result.head should be).a(Symbol("failure")) } - it should "serialize non-serializable and serializable messages and indicate whether or not the serialization succeeded" in { + it should + "serialize non-serializable and serializable messages and indicate whether or not the serialization succeeded" in { class Test val serializer = new ByteArrayJournalSerializer(serialization, ",") val result = serializer.serialize(List(AtomicWrite(PersistentRepr(new Test)), AtomicWrite(PersistentRepr("foo")))) diff --git a/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/CurrentEventsByTagTest.scala b/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/CurrentEventsByTagTest.scala index e37bebc..a274ba2 100644 --- a/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/CurrentEventsByTagTest.scala +++ b/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/CurrentEventsByTagTest.scala @@ -177,7 +177,8 @@ abstract class CurrentEventsByTagTest(config: String) extends QueryTestSpec(conf } } - it should "complete without any gaps in case events are being persisted when the query is executed" in withActorSystem { + it should "complete without any gaps in case events are being persisted when the query is executed" in + withActorSystem { implicit system => pendingIfOracleWithLegacy() diff --git a/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/JournalDaoStreamMessagesMemoryTest.scala b/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/JournalDaoStreamMessagesMemoryTest.scala index b6e3627..58f1f64 100644 --- a/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/JournalDaoStreamMessagesMemoryTest.scala +++ b/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/JournalDaoStreamMessagesMemoryTest.scala @@ -83,10 +83,9 @@ abstract class JournalDaoStreamMessagesMemoryTest(configFile: String) val end = i * eventsPerBatch val start = end - (eventsPerBatch - 1) log.info(s"batch $i - events from $start to $end") - val atomicWrites = - (start to end).map { j => - AtomicWrite(immutable.Seq(PersistentRepr(payload, j, persistenceId, writerUuid = writerUuid))) - } + val atomicWrites = (start to end).map { j => + AtomicWrite(immutable.Seq(PersistentRepr(payload, j, persistenceId, writerUuid = writerUuid))) + } dao.asyncWriteMessages(atomicWrites).map(_ => i) } .runWith(Sink.last) diff --git a/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/JournalSequenceActorTest.scala b/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/JournalSequenceActorTest.scala index ad8a169..582868e 100644 --- a/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/JournalSequenceActorTest.scala +++ b/core/src/test/scala/org/apache/pekko/persistence/jdbc/query/JournalSequenceActorTest.scala @@ -69,7 +69,8 @@ abstract class JournalSequenceActorTest(configFile: String, isOracle: Boolean) private def canForceInsert: Boolean = profile.capabilities.contains(JdbcCapabilities.forceInsert) if (canForceInsert && !newDao) { - it should s"recover ${if (isOracle) "one hundred thousand" else "one million"} events quickly if no ids are missing" in { + it should + s"recover ${if (isOracle) "one hundred thousand" else "one million"} events quickly if no ids are missing" in { withActorSystem { implicit system: ActorSystem => withDatabase { db => val elements = if (isOracle) 100000 else 1000000 @@ -100,7 +101,8 @@ abstract class JournalSequenceActorTest(configFile: String, isOracle: Boolean) if (!isOracle && canForceInsert && !newDao) { // Note this test case cannot be executed for oracle, because forceInsertAll is not supported in the oracle driver. - it should "recover after the specified max number if tries if the first event has a very high sequence number and lots of large gaps exist" in { + it should + "recover after the specified max number if tries if the first event has a very high sequence number and lots of large gaps exist" in { withActorSystem { implicit system: ActorSystem => withDatabase { db => val numElements = 1000 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 index 434483e..3d48d3f 100644 --- 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 @@ -307,8 +307,10 @@ abstract class QueryTestSpec(config: String, configOverrides: Map[String, Config } def pendingIfOracleWithLegacy(): Unit = { - if (profile == slick.jdbc.OracleProfile && readJournalConfig.pluginConfig.dao == classOf[ - pekko.persistence.jdbc.query.dao.legacy.ByteArrayReadJournalDao].getName) + if (profile == slick.jdbc.OracleProfile && + readJournalConfig.pluginConfig.dao == + classOf[ + pekko.persistence.jdbc.query.dao.legacy.ByteArrayReadJournalDao].getName) pending // TODO https://github.com/akka/akka-persistence-jdbc/issues/673 } diff --git a/core/src/test/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/JdbcDurableStateSpec.scala b/core/src/test/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/JdbcDurableStateSpec.scala index 119b1e8..035d0db 100644 --- a/core/src/test/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/JdbcDurableStateSpec.scala +++ b/core/src/test/scala/org/apache/pekko/persistence/jdbc/state/scaladsl/JdbcDurableStateSpec.scala @@ -257,7 +257,8 @@ abstract class JdbcDurableStateSpec(config: Config, schemaType: SchemaType) exte chgs.map(_.offset.value).max shouldBe 9 } - "find all states by tags with offsets sorted and proper max and min offsets when starting offset is specified" in withActorSystem { + "find all states by tags with offsets sorted and proper max and min offsets when starting offset is specified" in + withActorSystem { implicit system => val stateStoreString = new JdbcDurableStateStore[String](db, schemaTypeToProfile(schemaType), durableStateConfig, serialization) @@ -389,7 +390,8 @@ abstract class JdbcDurableStateSpec(config: Config, schemaType: SchemaType) exte } } - "fetch proper values of offsets from beginning for a larger dataset with changes() and phased upserts" in withActorSystem { + "fetch proper values of offsets from beginning for a larger dataset with changes() and phased upserts" in + withActorSystem { implicit system => val stateStoreString = new JdbcDurableStateStore[String](db, schemaTypeToProfile(schemaType), durableStateConfig, serialization) diff --git a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/AllPersistenceIdsTest.scala b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/AllPersistenceIdsTest.scala index a910014..7f89d4b 100644 --- a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/AllPersistenceIdsTest.scala +++ b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/AllPersistenceIdsTest.scala @@ -10,12 +10,7 @@ package org.apache.pekko.persistence.jdbc.integration import org.apache.pekko.persistence.jdbc.query.{ - AllPersistenceIdsTest, - MariaDBCleaner, - MysqlCleaner, - OracleCleaner, - PostgresCleaner, - SqlServerCleaner + AllPersistenceIdsTest, MariaDBCleaner, MysqlCleaner, OracleCleaner, PostgresCleaner, SqlServerCleaner } class PostgresScalaAllPersistenceIdsTest extends AllPersistenceIdsTest("postgres-application.conf") with PostgresCleaner diff --git a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentEventsByPersistenceIdTest.scala b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentEventsByPersistenceIdTest.scala index d71c225..c19bf37 100644 --- a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentEventsByPersistenceIdTest.scala +++ b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentEventsByPersistenceIdTest.scala @@ -10,12 +10,7 @@ package org.apache.pekko.persistence.jdbc.integration import org.apache.pekko.persistence.jdbc.query.{ - CurrentEventsByPersistenceIdTest, - MariaDBCleaner, - MysqlCleaner, - OracleCleaner, - PostgresCleaner, - SqlServerCleaner + CurrentEventsByPersistenceIdTest, MariaDBCleaner, MysqlCleaner, OracleCleaner, PostgresCleaner, SqlServerCleaner } // Note: these tests use the shared-db configs, the test for all (so not only current) events use the regular db config diff --git a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentEventsByTagTest.scala b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentEventsByTagTest.scala index 76946d7..80f19a4 100644 --- a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentEventsByTagTest.scala +++ b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentEventsByTagTest.scala @@ -10,12 +10,7 @@ package org.apache.pekko.persistence.jdbc.integration import org.apache.pekko.persistence.jdbc.query.{ - CurrentEventsByTagTest, - MariaDBCleaner, - MysqlCleaner, - OracleCleaner, - PostgresCleaner, - SqlServerCleaner + CurrentEventsByTagTest, MariaDBCleaner, MysqlCleaner, OracleCleaner, PostgresCleaner, SqlServerCleaner } // Note: these tests use the shared-db configs, the test for all (so not only current) events use the regular db config diff --git a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentLastKnownSequenceNumberByPersistenceIdTest.scala b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentLastKnownSequenceNumberByPersistenceIdTest.scala index 4f124f1..2c9b2b5 100644 --- a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentLastKnownSequenceNumberByPersistenceIdTest.scala +++ b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentLastKnownSequenceNumberByPersistenceIdTest.scala @@ -10,11 +10,7 @@ package org.apache.pekko.persistence.jdbc.integration import org.apache.pekko.persistence.jdbc.query.{ - CurrentLastSequenceNumberByPersistenceIdTest, - MariaDBCleaner, - MysqlCleaner, - OracleCleaner, - PostgresCleaner, + CurrentLastSequenceNumberByPersistenceIdTest, MariaDBCleaner, MysqlCleaner, OracleCleaner, PostgresCleaner, SqlServerCleaner } diff --git a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentPersistenceIdsTest.scala b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentPersistenceIdsTest.scala index baf2c07..02f5988 100644 --- a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentPersistenceIdsTest.scala +++ b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/CurrentPersistenceIdsTest.scala @@ -10,12 +10,7 @@ package org.apache.pekko.persistence.jdbc.integration import org.apache.pekko.persistence.jdbc.query.{ - CurrentPersistenceIdsTest, - MariaDBCleaner, - MysqlCleaner, - OracleCleaner, - PostgresCleaner, - SqlServerCleaner + CurrentPersistenceIdsTest, MariaDBCleaner, MysqlCleaner, OracleCleaner, PostgresCleaner, SqlServerCleaner } // Note: these tests use the shared-db configs, the test for all persistence ids use the regular db config diff --git a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/EventAdapterTest.scala b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/EventAdapterTest.scala index d6605b1..372b667 100644 --- a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/EventAdapterTest.scala +++ b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/EventAdapterTest.scala @@ -10,12 +10,7 @@ package org.apache.pekko.persistence.jdbc.integration import org.apache.pekko.persistence.jdbc.query.{ - EventAdapterTest, - MariaDBCleaner, - MysqlCleaner, - OracleCleaner, - PostgresCleaner, - SqlServerCleaner + EventAdapterTest, MariaDBCleaner, MysqlCleaner, OracleCleaner, PostgresCleaner, SqlServerCleaner } class PostgresScalaEventAdapterTest extends EventAdapterTest("postgres-application.conf") with PostgresCleaner diff --git a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/EventsByPersistenceIdTest.scala b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/EventsByPersistenceIdTest.scala index 0f5482e..f1ce63a 100644 --- a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/EventsByPersistenceIdTest.scala +++ b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/EventsByPersistenceIdTest.scala @@ -10,12 +10,7 @@ package org.apache.pekko.persistence.jdbc.integration import org.apache.pekko.persistence.jdbc.query.{ - EventsByPersistenceIdTest, - MariaDBCleaner, - MysqlCleaner, - OracleCleaner, - PostgresCleaner, - SqlServerCleaner + EventsByPersistenceIdTest, MariaDBCleaner, MysqlCleaner, OracleCleaner, PostgresCleaner, SqlServerCleaner } class PostgresScalaEventsByPersistenceIdTest diff --git a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/EventsByTagTest.scala b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/EventsByTagTest.scala index 877463f..85b6764 100644 --- a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/EventsByTagTest.scala +++ b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/EventsByTagTest.scala @@ -10,12 +10,7 @@ package org.apache.pekko.persistence.jdbc.integration import org.apache.pekko.persistence.jdbc.query.{ - EventsByTagTest, - MariaDBCleaner, - MysqlCleaner, - OracleCleaner, - PostgresCleaner, - SqlServerCleaner + EventsByTagTest, MariaDBCleaner, MysqlCleaner, OracleCleaner, PostgresCleaner, SqlServerCleaner } class PostgresScalaEventsByTagTest extends EventsByTagTest("postgres-application.conf") with PostgresCleaner diff --git a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/HardDeleteQueryTest.scala b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/HardDeleteQueryTest.scala index 8b7e711..78378ec 100644 --- a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/HardDeleteQueryTest.scala +++ b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/HardDeleteQueryTest.scala @@ -10,12 +10,7 @@ package org.apache.pekko.persistence.jdbc.integration import org.apache.pekko.persistence.jdbc.query.{ - HardDeleteQueryTest, - MariaDBCleaner, - MysqlCleaner, - OracleCleaner, - PostgresCleaner, - SqlServerCleaner + HardDeleteQueryTest, MariaDBCleaner, MysqlCleaner, OracleCleaner, PostgresCleaner, SqlServerCleaner } class PostgresHardDeleteQueryTest extends HardDeleteQueryTest("postgres-application.conf") with PostgresCleaner diff --git a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/JournalDaoStreamMessagesMemoryTest.scala b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/JournalDaoStreamMessagesMemoryTest.scala index d4335c9..f4183d4 100644 --- a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/JournalDaoStreamMessagesMemoryTest.scala +++ b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/JournalDaoStreamMessagesMemoryTest.scala @@ -10,12 +10,7 @@ package org.apache.pekko.persistence.jdbc.integration import org.apache.pekko.persistence.jdbc.query.{ - JournalDaoStreamMessagesMemoryTest, - MariaDBCleaner, - MysqlCleaner, - OracleCleaner, - PostgresCleaner, - SqlServerCleaner + JournalDaoStreamMessagesMemoryTest, MariaDBCleaner, MysqlCleaner, OracleCleaner, PostgresCleaner, SqlServerCleaner } class PostgresJournalDaoStreamMessagesMemoryTest diff --git a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/JournalSequenceActorTest.scala b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/JournalSequenceActorTest.scala index 09688c1..e4ee373 100644 --- a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/JournalSequenceActorTest.scala +++ b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/JournalSequenceActorTest.scala @@ -10,12 +10,7 @@ package org.apache.pekko.persistence.jdbc.integration import org.apache.pekko.persistence.jdbc.query.{ - JournalSequenceActorTest, - MariaDBCleaner, - MysqlCleaner, - OracleCleaner, - PostgresCleaner, - SqlServerCleaner + JournalSequenceActorTest, MariaDBCleaner, MysqlCleaner, OracleCleaner, PostgresCleaner, SqlServerCleaner } class PostgresJournalSequenceActorTest diff --git a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/LimitWindowingStreamTest.scala b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/LimitWindowingStreamTest.scala index a1c023c..224304a 100644 --- a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/LimitWindowingStreamTest.scala +++ b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/LimitWindowingStreamTest.scala @@ -21,11 +21,7 @@ package org.apache.pekko.persistence.jdbc.integration import org.apache.pekko.persistence.jdbc.journal.dao.LimitWindowingStreamTest import org.apache.pekko.persistence.jdbc.query.{ - MariaDBCleaner, - MysqlCleaner, - OracleCleaner, - PostgresCleaner, - SqlServerCleaner + MariaDBCleaner, MysqlCleaner, OracleCleaner, PostgresCleaner, SqlServerCleaner } class PostgresLimitWindowingStreamTest diff --git a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/MariaDBDurableStateStorePluginSpec.scala b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/MariaDBDurableStateStorePluginSpec.scala index 63fb5ed..0ac66a0 100644 --- a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/MariaDBDurableStateStorePluginSpec.scala +++ b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/MariaDBDurableStateStorePluginSpec.scala @@ -20,8 +20,7 @@ package org.apache.pekko.persistence.jdbc.integration import com.typesafe.config.ConfigFactory import org.apache.pekko.persistence.jdbc.db.MariaDBProfile import org.apache.pekko.persistence.jdbc.state.scaladsl.{ - DurableStateStorePluginSpec, - DurableStateStoreSchemaPluginSpec + DurableStateStorePluginSpec, DurableStateStoreSchemaPluginSpec } class MariaDBDurableStateStorePluginSpec diff --git a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/MySQLDurableStateStorePluginSpec.scala b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/MySQLDurableStateStorePluginSpec.scala index e0af3b7..db1add1 100644 --- a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/MySQLDurableStateStorePluginSpec.scala +++ b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/MySQLDurableStateStorePluginSpec.scala @@ -19,8 +19,7 @@ package org.apache.pekko.persistence.jdbc.integration import com.typesafe.config.ConfigFactory import org.apache.pekko.persistence.jdbc.state.scaladsl.{ - DurableStateStorePluginSpec, - DurableStateStoreSchemaPluginSpec + DurableStateStorePluginSpec, DurableStateStoreSchemaPluginSpec } import slick.jdbc.MySQLProfile diff --git a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/PostgresDurableStateStorePluginSpec.scala b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/PostgresDurableStateStorePluginSpec.scala index b0b1975..9e96762 100644 --- a/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/PostgresDurableStateStorePluginSpec.scala +++ b/integration-test/src/test/scala/org/apache/pekko/persistence/jdbc/integration/PostgresDurableStateStorePluginSpec.scala @@ -12,8 +12,7 @@ package org.apache.pekko.persistence.jdbc.integration import com.typesafe.config.ConfigFactory import slick.jdbc.PostgresProfile import org.apache.pekko.persistence.jdbc.state.scaladsl.{ - DurableStateStorePluginSpec, - DurableStateStoreSchemaPluginSpec + DurableStateStorePluginSpec, DurableStateStoreSchemaPluginSpec } class PostgresDurableStateStorePluginSpec diff --git a/project/ProjectAutoPlugin.scala b/project/ProjectAutoPlugin.scala index 62bf956..f81cf5f 100644 --- a/project/ProjectAutoPlugin.scala +++ b/project/ProjectAutoPlugin.scala @@ -50,12 +50,13 @@ object ProjectAutoPlugin extends AutoPlugin { "-language:higherKinds", "-language:implicitConversions", "-release:17"), - Compile / scalacOptions ++= (CrossVersion.partialVersion(scalaVersion.value) match { - case Some((2, _)) => - disciplineScalacOptions - case _ => - Nil - }).toSeq, + Compile / scalacOptions ++= + (CrossVersion.partialVersion(scalaVersion.value) match { + case Some((2, _)) => + disciplineScalacOptions + case _ => + Nil + }).toSeq, scalacOptions += "-Ydelambdafy:method", Compile / javacOptions ++= Seq( "-encoding", --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
