This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new b7f314789 use deprecated since marker (#1729)
b7f314789 is described below
commit b7f31478929a9c89ae22e4c0561c3b0ca8a6d92c
Author: PJ Fanning <[email protected]>
AuthorDate: Sat Jun 27 10:56:53 2026 +0100
use deprecated since marker (#1729)
* use deprecated since marker
* Update CassandraFlow.scala
* Update FcmSettings.scala
---
.../pekko/stream/connectors/cassandra/javadsl/CassandraFlow.scala | 2 +-
.../connectors/googlecloud/pubsub/grpc/PubSubSettings.scala | 2 +-
.../apache/pekko/stream/connectors/googlecloud/pubsub/model.scala | 2 +-
.../pekko/stream/connectors/google/firebase/fcm/FcmSettings.scala | 2 --
.../org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala | 8 ++++----
5 files changed, 7 insertions(+), 9 deletions(-)
diff --git
a/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraFlow.scala
b/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraFlow.scala
index 06be7daca..7f8403f96 100644
---
a/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraFlow.scala
+++
b/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraFlow.scala
@@ -90,7 +90,7 @@ object CassandraFlow {
* @deprecated Use [[createUnloggedBatch]] with
`pekko.japi.function.Function2` for `statementBinder` instead (since 2.0.0).
*/
@deprecated("Use createUnloggedBatch with pekko.japi.function.Function2 for
statementBinder instead", "2.0.0")
- @java.lang.Deprecated
+ @java.lang.Deprecated(since = "2.0.0")
def createUnloggedBatchWithScalaStatementBinder[T, K](session:
CassandraSession,
writeSettings: CassandraWriteSettings,
cqlStatement: String,
diff --git
a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/PubSubSettings.scala
b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/PubSubSettings.scala
index ad16e7c90..42c50b168 100644
---
a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/PubSubSettings.scala
+++
b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/PubSubSettings.scala
@@ -32,7 +32,7 @@ final class PubSubSettings private (
/** @deprecated Use [[pekko.stream.connectors.google.GoogleSettings]] */
@deprecated(
"Use org.apache.pekko.stream.connectors.google.GoogleSettings",
- "Alpakka 3.0.0") @Deprecated val callCredentials: Option[
+ "Alpakka 3.0.0") @Deprecated(since = "Alpakka 3.0.0") val
callCredentials: Option[
CallCredentials]) {
/**
diff --git
a/google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/model.scala
b/google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/model.scala
index 14e648712..e88d97585 100644
---
a/google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/model.scala
+++
b/google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/model.scala
@@ -31,7 +31,7 @@ class PubSubConfig private (
/** @deprecated Use [[pekko.stream.connectors.google.GoogleSettings]] */
@deprecated(
"Use org.apache.pekko.stream.connectors.google.GoogleSettings",
- "Alpakka 3.0.0") @Deprecated val projectId: String,
+ "Alpakka 3.0.0") @Deprecated(since = "Alpakka 3.0.0") val projectId:
String,
val pullReturnImmediately: Boolean,
val pullMaxMessagesPerInternalBatch: Int,
@deprecated("Added only to help with migration", "Alpakka 3.0.0")
@InternalApi private[pubsub] val settings: Option[
diff --git
a/google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmSettings.scala
b/google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmSettings.scala
index 3883936bc..5ca35505e 100644
---
a/google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmSettings.scala
+++
b/google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/FcmSettings.scala
@@ -16,9 +16,7 @@ package org.apache.pekko.stream.connectors.google.firebase.fcm
import org.apache.pekko
import java.util.Objects
-import scala.annotation.nowarn
-@nowarn("msg=deprecated")
final class FcmSettings private (
val isTest: Boolean,
val maxConcurrentConnections: Int) {
diff --git
a/slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala
b/slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala
index 57128e8cd..ab1c26f6f 100644
---
a/slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala
+++
b/slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala
@@ -154,7 +154,7 @@ object Slick {
* @deprecated Use the overload with `java.util.concurrent.Executor` instead.
*/
@deprecated("Use flowWithPassThrough with java.util.concurrent.Executor
instead", "2.0.0")
- @java.lang.Deprecated
+ @java.lang.Deprecated(since = "2.0.0")
def flowWithPassThrough[T, R](
session: SlickSession,
executionContext: ExecutionContext,
@@ -226,7 +226,7 @@ object Slick {
* @deprecated Use the overload with `java.util.concurrent.Executor` instead
(since 2.0.0).
*/
@deprecated("Use flowWithPassThrough with java.util.concurrent.Executor
instead", "2.0.0")
- @java.lang.Deprecated
+ @java.lang.Deprecated(since = "2.0.0")
def flowWithPassThrough[T, R](
session: SlickSession,
executionContext: ExecutionContext,
@@ -301,7 +301,7 @@ object Slick {
* @deprecated Use the overload with `java.util.concurrent.Executor` instead.
*/
@deprecated("Use flowWithPassThrough with java.util.concurrent.Executor
instead", "2.0.0")
- @java.lang.Deprecated
+ @java.lang.Deprecated(since = "2.0.0")
def flowWithPassThrough[T, R](
session: SlickSession,
executionContext: ExecutionContext,
@@ -409,7 +409,7 @@ object Slick {
* @deprecated Use the overload with `java.util.concurrent.Executor` instead.
*/
@deprecated("Use flowWithPassThrough with java.util.concurrent.Executor
instead", "2.0.0")
- @java.lang.Deprecated
+ @java.lang.Deprecated(since = "2.0.0")
def flowWithPassThrough[T, R](
session: SlickSession,
executionContext: ExecutionContext,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
