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-projection.git
The following commit(s) were added to refs/heads/main by this push:
new a0d9e8b remove deprecated code (#314)
a0d9e8b is described below
commit a0d9e8b4e7c6a9e7e32bd9b69e0af60eb379f1e4
Author: PJ Fanning <[email protected]>
AuthorDate: Sun Sep 28 17:07:16 2025 +0100
remove deprecated code (#314)
* remove deprecated code
* mima
* Create remove-deprecated-code.excludes
---
.../remove-deprecated-code.excludes | 20 +++++++++++++++++++
.../cassandra/javadsl/CassandraProjection.scala | 4 ----
.../cassandra/scaladsl/CassandraProjection.scala | 4 ----
.../remove-deprecated-code.excludes | 23 ++++++++++++++++++++++
.../projection/jdbc/javadsl/JdbcHandler.scala | 4 ----
.../projection/jdbc/javadsl/JdbcProjection.scala | 11 -----------
.../projection/jdbc/scaladsl/JdbcProjection.scala | 10 ----------
.../remove-deprecated-code.excludes | 20 +++++++++++++++++++
.../pekko/projection/slick/SlickProjection.scala | 10 ----------
9 files changed, 63 insertions(+), 43 deletions(-)
diff --git
a/cassandra/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-code.excludes
b/cassandra/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-code.excludes
new file mode 100644
index 0000000..40842ca
--- /dev/null
+++
b/cassandra/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-code.excludes
@@ -0,0 +1,20 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied. See the License for the
+# specific language governing permissions and limitations
+# under the License.
+
+# Remove deprecated code
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.projection.cassandra.javadsl.CassandraProjection.createOffsetTableIfNotExists")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.projection.cassandra.scaladsl.CassandraProjection.createOffsetTableIfNotExists")
diff --git
a/cassandra/src/main/scala/org/apache/pekko/projection/cassandra/javadsl/CassandraProjection.scala
b/cassandra/src/main/scala/org/apache/pekko/projection/cassandra/javadsl/CassandraProjection.scala
index f253f5d..2efeba7 100644
---
a/cassandra/src/main/scala/org/apache/pekko/projection/cassandra/javadsl/CassandraProjection.scala
+++
b/cassandra/src/main/scala/org/apache/pekko/projection/cassandra/javadsl/CassandraProjection.scala
@@ -159,8 +159,4 @@ object CassandraProjection {
val offsetStore = new CassandraOffsetStore(system)
offsetStore.createKeyspaceAndTable().asJava
}
-
- @deprecated("Renamed to createTablesIfNotExists", "1.2.0")
- def createOffsetTableIfNotExists(system: ActorSystem[_]):
CompletionStage[Done] =
- createTablesIfNotExists(system)
}
diff --git
a/cassandra/src/main/scala/org/apache/pekko/projection/cassandra/scaladsl/CassandraProjection.scala
b/cassandra/src/main/scala/org/apache/pekko/projection/cassandra/scaladsl/CassandraProjection.scala
index cf3de55..8565c88 100644
---
a/cassandra/src/main/scala/org/apache/pekko/projection/cassandra/scaladsl/CassandraProjection.scala
+++
b/cassandra/src/main/scala/org/apache/pekko/projection/cassandra/scaladsl/CassandraProjection.scala
@@ -161,8 +161,4 @@ object CassandraProjection {
offsetStore.createKeyspaceAndTable()
}
- @deprecated("Renamed to createTablesIfNotExists", "1.2.0")
- def createOffsetTableIfNotExists()(implicit system: ActorSystem[_]):
Future[Done] =
- createTablesIfNotExists()
-
}
diff --git
a/jdbc/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-code.excludes
b/jdbc/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-code.excludes
new file mode 100644
index 0000000..bb731bd
--- /dev/null
+++
b/jdbc/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-code.excludes
@@ -0,0 +1,23 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied. See the License for the
+# specific language governing permissions and limitations
+# under the License.
+
+# Remove deprecated code
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.projection.jdbc.javadsl.JdbcHandler.fromFunction")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.projection.jdbc.javadsl.JdbcProjection.createOffsetTableIfNotExists")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.projection.jdbc.javadsl.JdbcProjection.dropOffsetTableIfExists")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.projection.jdbc.scaladsl.JdbcProjection.createOffsetTableIfNotExists")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.projection.jdbc.scaladsl.JdbcProjection.dropOffsetTableIfExists")
diff --git
a/jdbc/src/main/scala/org/apache/pekko/projection/jdbc/javadsl/JdbcHandler.scala
b/jdbc/src/main/scala/org/apache/pekko/projection/jdbc/javadsl/JdbcHandler.scala
index 1bf7177..767a6cf 100644
---
a/jdbc/src/main/scala/org/apache/pekko/projection/jdbc/javadsl/JdbcHandler.scala
+++
b/jdbc/src/main/scala/org/apache/pekko/projection/jdbc/javadsl/JdbcHandler.scala
@@ -35,10 +35,6 @@ object JdbcHandler {
override def process(session: S, envelope: Envelope): Unit =
handler.accept(session, envelope)
}
- @deprecated("Use the similar method with Java functional interface as a
parameter", "1.2.1")
- def fromFunction[Envelope, S <: JdbcSession](handler: (S, Envelope) =>
Unit): JdbcHandler[Envelope, S] =
- new HandlerFunction((s, env) => handler(s, env))
-
def fromFunction[Envelope, S <: JdbcSession](handler: BiConsumer[S,
Envelope]): JdbcHandler[Envelope, S] =
new HandlerFunction(handler)
}
diff --git
a/jdbc/src/main/scala/org/apache/pekko/projection/jdbc/javadsl/JdbcProjection.scala
b/jdbc/src/main/scala/org/apache/pekko/projection/jdbc/javadsl/JdbcProjection.scala
index b0ef72d..8c7f2fb 100644
---
a/jdbc/src/main/scala/org/apache/pekko/projection/jdbc/javadsl/JdbcProjection.scala
+++
b/jdbc/src/main/scala/org/apache/pekko/projection/jdbc/javadsl/JdbcProjection.scala
@@ -295,21 +295,10 @@ object JdbcProjection {
system: ActorSystem[_]): CompletionStage[Done] =
JdbcProjectionImpl.createOffsetStore(() =>
sessionFactory.get())(system).createIfNotExists().asJava
- @deprecated("Renamed to createTablesIfNotExists", "1.2.0")
- def createOffsetTableIfNotExists[S <: JdbcSession](
- sessionFactory: Supplier[S],
- system: ActorSystem[_]): CompletionStage[Done] =
- createTablesIfNotExists(sessionFactory, system)
-
/**
* For testing purposes the projection offset and management tables can be
dropped programmatically.
*/
def dropTablesIfExists[S <: JdbcSession](sessionFactory: Supplier[S],
system: ActorSystem[_]): CompletionStage[Done] =
JdbcProjectionImpl.createOffsetStore(() =>
sessionFactory.get())(system).dropIfExists().asJava
- @deprecated("Renamed to dropTablesIfExists", "1.2.0")
- def dropOffsetTableIfExists[S <: JdbcSession](
- sessionFactory: Supplier[S],
- system: ActorSystem[_]): CompletionStage[Done] =
- dropTablesIfExists(sessionFactory, system)
}
diff --git
a/jdbc/src/main/scala/org/apache/pekko/projection/jdbc/scaladsl/JdbcProjection.scala
b/jdbc/src/main/scala/org/apache/pekko/projection/jdbc/scaladsl/JdbcProjection.scala
index 51ccc9d..556b064 100644
---
a/jdbc/src/main/scala/org/apache/pekko/projection/jdbc/scaladsl/JdbcProjection.scala
+++
b/jdbc/src/main/scala/org/apache/pekko/projection/jdbc/scaladsl/JdbcProjection.scala
@@ -272,20 +272,10 @@ object JdbcProjection {
implicit system: ActorSystem[_]): Future[Done] =
JdbcProjectionImpl.createOffsetStore(sessionFactory).createIfNotExists()
- @deprecated("Renamed to createTablesIfNotExists", "1.2.0")
- def createOffsetTableIfNotExists[S <: JdbcSession](sessionFactory: () => S)(
- implicit system: ActorSystem[_]): Future[Done] =
- createTablesIfNotExists(sessionFactory)
-
/**
* For testing purposes the projection offset and management tables can be
dropped programmatically.
*/
def dropTablesIfExists[S <: JdbcSession](sessionFactory: () => S)(implicit
system: ActorSystem[_]): Future[Done] =
JdbcProjectionImpl.createOffsetStore(sessionFactory).dropIfExists()
- @deprecated("Renamed to dropTablesIfExists", "1.2.0")
- def dropOffsetTableIfExists[S <: JdbcSession](sessionFactory: () => S)(
- implicit system: ActorSystem[_]): Future[Done] =
- dropTablesIfExists(sessionFactory)
-
}
diff --git
a/slick/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-code.excludes
b/slick/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-code.excludes
new file mode 100644
index 0000000..e3d424c
--- /dev/null
+++
b/slick/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-code.excludes
@@ -0,0 +1,20 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied. See the License for the
+# specific language governing permissions and limitations
+# under the License.
+
+# Remove deprecated code
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.projection.slick.SlickProjection.createOffsetTableIfNotExists")
+ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.projection.slick.SlickProjection.dropOffsetTableIfExists")
diff --git
a/slick/src/main/scala/org/apache/pekko/projection/slick/SlickProjection.scala
b/slick/src/main/scala/org/apache/pekko/projection/slick/SlickProjection.scala
index 10e88e1..1ae50d9 100644
---
a/slick/src/main/scala/org/apache/pekko/projection/slick/SlickProjection.scala
+++
b/slick/src/main/scala/org/apache/pekko/projection/slick/SlickProjection.scala
@@ -375,11 +375,6 @@ object SlickProjection {
createOffsetStore(databaseConfig).createIfNotExists()
}
- @deprecated("Renamed to createTablesIfNotExists", "1.2.0")
- def createOffsetTableIfNotExists[P <: JdbcProfile: ClassTag](databaseConfig:
DatabaseConfig[P])(
- implicit system: ActorSystem[_]): Future[Done] =
- createTablesIfNotExists(databaseConfig)
-
/**
* For testing purposes the projection offset and management tables can be
dropped programmatically.
*/
@@ -388,11 +383,6 @@ object SlickProjection {
createOffsetStore(databaseConfig).dropIfExists()
}
- @deprecated("Renamed to dropTablesIfExists", "1.2.0")
- def dropOffsetTableIfExists[P <: JdbcProfile: ClassTag](databaseConfig:
DatabaseConfig[P])(
- implicit system: ActorSystem[_]): Future[Done] =
- dropTablesIfExists(databaseConfig)
-
private def createOffsetStore[P <: JdbcProfile: ClassTag](databaseConfig:
DatabaseConfig[P])(
implicit system: ActorSystem[_]) =
new SlickOffsetStore(system, databaseConfig, SlickSettings(system))
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
