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/incubator-pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new 2b5fcd119 Switch some Akka/Alpakka references to Pekko (#107)
2b5fcd119 is described below
commit 2b5fcd11937270d0995f788486cb9cc4216067fb
Author: PJ Fanning <[email protected]>
AuthorDate: Tue May 16 22:24:44 2023 +0100
Switch some Akka/Alpakka references to Pekko (#107)
* Switch some Akka/Alpakka references to Pekko
* scalafmt
* more updates
* test issue
* test issues
* Update HdfsWriterTest.java
* Update model.scala
---
README.md | 2 +-
.../docs/javadsl/EventBridgePublisherTest.java | 2 +-
.../aws/eventbridge/IntegrationTestContext.scala | 2 +-
awslambda/src/test/java/docs/javadsl/Examples.java | 4 +-
.../src/test/scala/docs/scaladsl/Examples.scala | 4 +-
build.sbt | 20 ++---
.../cassandra/PekkoDiscoverySessionProvider.scala | 2 +-
contributor-advice.md | 4 +-
.../couchbase/javadsl/DiscoverySupport.java | 2 +-
.../couchbase/scaladsl/DiscoverySupport.scala | 4 +-
.../stream/connectors/csv/scaladsl/CsvBench.scala | 2 +-
docs/src/main/paradox/.htaccess | 9 --
docs/src/main/paradox/_template/logo.st | 1 -
docs/src/main/paradox/external/grpc.md | 4 +-
docs/src/main/paradox/index.md | 2 +-
docs/src/main/paradox/kafka.md | 2 +-
docs/src/main/paradox/other-docs/snapshots.md | 2 +-
docs/src/main/paradox/overview.md | 12 +--
docs/src/main/paradox/release-notes/index.md | 2 +-
.../src/test/java/docs/javadsl/ExampleTest.java | 4 +-
.../src/test/scala/docs/scaladsl/ExampleSpec.scala | 4 +-
file/src/test/java/docs/javadsl/ArchiveTest.java | 6 +-
.../java/docs/javadsl/NestedTarReaderTest.java | 2 +-
.../src/test/scala/docs/scaladsl/ArchiveSpec.scala | 2 +-
.../test/scala/docs/scaladsl/TarArchiveSpec.scala | 2 +-
.../stream/connectors/ftp/BaseSupportImpl.java | 2 +-
.../src/main/resources/reference.conf | 2 +-
.../bigquery/storage/BigQueryStorageSpecBase.scala | 2 +-
.../src/test/resources/BigQueryEndToEndSpec.json | 54 ++++++------
.../src/test/resources/application.conf | 4 +-
.../src/test/java/docs/javadsl/GCStorageTest.java | 4 +-
.../scala/docs/scaladsl/GCStorageSinkSpec.scala | 4 +-
.../impl/GCStorageStreamIntegrationSpec.scala | 4 +-
google-common/src/test/resources/application.conf | 2 +-
.../pekko/stream/connectors/hdfs/model.scala | 4 +-
.../src/test/java/docs/javadsl/HdfsWriterTest.java | 2 +-
.../test/scala/docs/scaladsl/HdfsReaderSpec.scala | 2 +-
.../test/scala/docs/scaladsl/HdfsWriterSpec.scala | 4 +-
.../stream/connectors/hdfs/util/TestUtils.scala | 2 +-
.../src/test/java/docs/javadsl/IronMqDocsTest.java | 4 +-
jms/src/main/resources/reference.conf | 4 +-
.../java/docs/javadsl/KinesisFirehoseSnippets.java | 2 +-
.../test/java/docs/javadsl/KinesisSnippets.java | 2 +-
.../docs/scaladsl/KinesisFirehoseSnippets.scala | 2 +-
.../test/scala/docs/scaladsl/KinesisSnippets.scala | 2 +-
project/Common.scala | 5 +-
project/Dependencies.scala | 6 +-
project/project-info.conf | 96 +++++++++++-----------
s3/src/main/resources/reference.conf | 2 +-
scripts/link-validator.conf | 10 +--
slick/src/test/java/docs/javadsl/SlickTest.java | 2 +-
slick/src/test/resources/application.conf | 4 +-
slick/src/test/scala/docs/scaladsl/SlickSpec.scala | 2 +-
.../test/java/docs/javadsl/SnsPublisherTest.java | 6 +-
.../connectors/sns/IntegrationTestContext.scala | 7 +-
.../connectors/sqs/javadsl/SqsPublishFlow.scala | 2 +-
.../connectors/sqs/javadsl/SqsPublishSink.scala | 6 +-
.../connectors/sqs/scaladsl/SqsPublishFlow.scala | 2 +-
.../connectors/sqs/scaladsl/SqsPublishSink.scala | 6 +-
sqs/src/test/java/docs/javadsl/SqsPublishTest.java | 18 ++--
sqs/src/test/java/docs/javadsl/SqsSourceTest.java | 2 +-
.../stream/connectors/sqs/javadsl/BaseSqsTest.java | 4 +-
sqs/src/test/scala/docs/scaladsl/SqsAckSpec.scala | 14 ++--
.../test/scala/docs/scaladsl/SqsSourceSpec.scala | 2 +-
.../sqs/scaladsl/DefaultTestContext.scala | 4 +-
.../connectors/testkit/CapturingAppender.scala | 4 +-
.../stream/connectors/testkit/LogbackUtil.scala | 2 +-
.../testkit/javadsl/LogCapturingJunit4.scala | 2 +-
.../connectors/testkit/scaladsl/LogCapturing.scala | 2 +-
69 files changed, 206 insertions(+), 214 deletions(-)
diff --git a/README.md b/README.md
index 1ff51f950..7df5491e3 100644
--- a/README.md
+++ b/README.md
@@ -8,7 +8,7 @@ Apache Pekko Connectors [![scaladex-badge][]][scaladex]
[![maven-central-badge][
Systems don't come alone. In the modern world of microservices and cloud
deployment, new components must interact with legacy systems, making
integration an important key to success. Reactive Streams give us a
technology-independent tool to let these heterogeneous systems communicate
without overwhelming each other.
-The Apache Pekko Connectors project is an open source initiative to implement
stream-aware, reactive, integration pipelines for Java and Scala. It is built
on top of Pekko Streams, and has been designed from the ground up to understand
streaming natively and provide a DSL for reactive and stream-oriented
programming, with built-in support for backpressure. Pekko Streams is a
[Reactive Streams](http://www.reactive-streams.org/) and JDK 9+
[java.util.concurrent.Flow](https://docs.oracle.co [...]
+The Apache Pekko Connectors project is an open source initiative to implement
stream-aware, reactive, integration pipelines for Java and Scala. It is built
on top of Pekko Streams, and has been designed from the ground up to understand
streaming natively and provide a DSL for reactive and stream-oriented
programming, with built-in support for backpressure. Pekko Streams is a
[Reactive Streams](http://www.reactive-streams.org/) and JDK 9+
[java.util.concurrent.Flow](https://docs.oracle.co [...]
Pekko Connectors is a fork of [Alpakka](https://github.com/akka/alpakka)
4.0.0, prior to the Akka project's adoption of the Business Source License.
diff --git
a/aws-event-bridge/src/test/java/docs/javadsl/EventBridgePublisherTest.java
b/aws-event-bridge/src/test/java/docs/javadsl/EventBridgePublisherTest.java
index 2b7fada18..ae33c8590 100644
--- a/aws-event-bridge/src/test/java/docs/javadsl/EventBridgePublisherTest.java
+++ b/aws-event-bridge/src/test/java/docs/javadsl/EventBridgePublisherTest.java
@@ -70,7 +70,7 @@ public class EventBridgePublisherTest {
eventBridgeClient
.createEventBus(
CreateEventBusRequest.builder()
- .name("alpakka-java-eventbus-" +
UUID.randomUUID().toString())
+ .name("pekko-connectors-java-eventbus-" +
UUID.randomUUID().toString())
.build())
.get()
.eventBusArn();
diff --git
a/aws-event-bridge/src/test/scala/org/apache/pekko/stream/connectors/aws/eventbridge/IntegrationTestContext.scala
b/aws-event-bridge/src/test/scala/org/apache/pekko/stream/connectors/aws/eventbridge/IntegrationTestContext.scala
index 2f5aaf961..7d6ab307c 100644
---
a/aws-event-bridge/src/test/scala/org/apache/pekko/stream/connectors/aws/eventbridge/IntegrationTestContext.scala
+++
b/aws-event-bridge/src/test/scala/org/apache/pekko/stream/connectors/aws/eventbridge/IntegrationTestContext.scala
@@ -40,7 +40,7 @@ trait IntegrationTestContext extends BeforeAndAfterAll with
ScalaFutures {
def createEventBus(): String =
eventBridgeClient
.createEventBus(
-
CreateEventBusRequest.builder().name(s"alpakka-topic-${UUID.randomUUID().toString}").build())
+
CreateEventBusRequest.builder().name(s"pekko-connectors-topic-${UUID.randomUUID().toString}").build())
.get()
.eventBusArn()
diff --git a/awslambda/src/test/java/docs/javadsl/Examples.java
b/awslambda/src/test/java/docs/javadsl/Examples.java
index 2e1710429..7ea8a5fbb 100644
--- a/awslambda/src/test/java/docs/javadsl/Examples.java
+++ b/awslambda/src/test/java/docs/javadsl/Examples.java
@@ -47,7 +47,7 @@ public class Examples {
// #init-client
// Don't encode credentials in your source code!
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
StaticCredentialsProvider credentialsProvider =
StaticCredentialsProvider.create(AwsBasicCredentials.create("x", "x"));
LambdaAsyncClient awsLambdaClient =
@@ -55,7 +55,7 @@ public class Examples {
.credentialsProvider(credentialsProvider)
.httpClient(PekkoHttpClient.builder().withActorSystem(system).build())
// Possibility to configure the retry policy
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
// .overrideConfiguration(...)
.build();
diff --git a/awslambda/src/test/scala/docs/scaladsl/Examples.scala
b/awslambda/src/test/scala/docs/scaladsl/Examples.scala
index b75e56897..2ca001480 100644
--- a/awslambda/src/test/scala/docs/scaladsl/Examples.scala
+++ b/awslambda/src/test/scala/docs/scaladsl/Examples.scala
@@ -33,14 +33,14 @@ object Examples {
import software.amazon.awssdk.services.lambda.LambdaAsyncClient
// Don't encode credentials in your source code!
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
val credentialsProvider =
StaticCredentialsProvider.create(AwsBasicCredentials.create("x", "x"))
implicit val lambdaClient: LambdaAsyncClient = LambdaAsyncClient
.builder()
.credentialsProvider(credentialsProvider)
.httpClient(PekkoHttpClient.builder().withActorSystem(system).build())
// Possibility to configure the retry policy
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
// .overrideConfiguration(...)
.build()
diff --git a/build.sbt b/build.sbt
index bf456fdab..6627cdcca 100644
--- a/build.sbt
+++ b/build.sbt
@@ -326,14 +326,14 @@ lazy val docs = project
pekkoParadoxGithub :=
Some("https://github.com/apache/incubator-pekko-connectors";),
makeSite := makeSite.dependsOn(LocalRootProject / ScalaUnidoc / doc).value,
previewPath := (Paradox / siteSubdirName).value,
- Preprocess / siteSubdirName := s"api/alpakka/${projectInfoVersion.value}",
+ Preprocess / siteSubdirName :=
s"api/pekko-connectors/${projectInfoVersion.value}",
Preprocess / sourceDirectory := (LocalRootProject / ScalaUnidoc / unidoc /
target).value,
Preprocess / preprocessRules := Seq(
("http://www\\.eclipse\\.org/".r, _ => "https://www\\.eclipse\\.org/";),
("http://pravega\\.io/".r, _ => "https://pravega\\.io/";),
("http://www\\.scala-lang\\.org/".r, _ =>
"https://www\\.scala-lang\\.org/";),
("https://javadoc\\.io/page/".r, _ => "https://javadoc\\.io/static/";)),
- Paradox / siteSubdirName := s"docs/alpakka/${projectInfoVersion.value}",
+ Paradox / siteSubdirName :=
s"docs/pekko-connectors/${projectInfoVersion.value}",
paradoxProperties ++= Map(
"pekko.version" -> Dependencies.PekkoVersion,
"pekko-http.version" -> Dependencies.PekkoHttpVersion,
@@ -341,15 +341,15 @@ lazy val docs = project
"extref.github.base_url" ->
s"https://github.com/apache/incubator-pekko-connectors/tree/${if
(isSnapshot.value) "main"
else "v" + version.value}/%s",
"extref.pekko.base_url" ->
s"https://pekko.apache.org/docs/pekko/current/%s";,
- "scaladoc.akka.base_url" ->
s"https://doc.akka.io/api/akka/${Dependencies.AkkaBinaryVersion}";,
- "javadoc.akka.base_url" ->
s"https://doc.akka.io/japi/akka/${Dependencies.AkkaBinaryVersion}/";,
- "javadoc.akka.link_style" -> "direct",
- "extref.pekko-http.base_url" ->
s"https://doc.akka.io/docs/akka-http/${Dependencies.AkkaHttpBinaryVersion}/%s";,
- "scaladoc.akka.http.base_url" ->
s"https://doc.akka.io/api/akka-http/${Dependencies.AkkaHttpBinaryVersion}/";,
- "javadoc.akka.http.base_url" ->
s"https://doc.akka.io/japi/akka-http/${Dependencies.AkkaHttpBinaryVersion}/";,
- // Akka gRPC
+ "scaladoc.pekko.base_url" ->
s"https://pekko.apache.org/api/pekko/${Dependencies.PekkoBinaryVersion}";,
+ "javadoc.pekko.base_url" ->
s"https://pekko.apache.org/japi/pekko/${Dependencies.PekkoBinaryVersion}/";,
+ "javadoc.pekko.link_style" -> "direct",
+ "extref.pekko-http.base_url" ->
s"https://pekko.apache.org/docs/pekko-http/${Dependencies.PekkoHttpBinaryVersion}/%s";,
+ "scaladoc.pekko.http.base_url" ->
s"https://pekko.apache.org/api/pekko-http/${Dependencies.PekkoHttpBinaryVersion}/";,
+ "javadoc.pekko.http.base_url" ->
s"https://pekko.apache.org/japi/pekko-http/${Dependencies.PekkoHttpBinaryVersion}/";,
+ // Pekko gRPC
"pekko-grpc.version" -> Dependencies.PekkoGrpcBinaryVersion,
- "extref.pekko-grpc.base_url" ->
s"https://doc.akka.io/docs/pekko-grpc/${Dependencies.PekkoGrpcBinaryVersion}/%s";,
+ "extref.pekko-grpc.base_url" ->
s"https://pekko.apache.org/docs/pekko-grpc/${Dependencies.PekkoGrpcBinaryVersion}/%s";,
// Couchbase
"couchbase.version" -> Dependencies.CouchbaseVersion,
"extref.couchbase.base_url" ->
s"https://docs.couchbase.com/java-sdk/${Dependencies.CouchbaseVersionForDocs}/%s";,
diff --git
a/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/PekkoDiscoverySessionProvider.scala
b/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/PekkoDiscoverySessionProvider.scala
index 23e6305e3..89bd27bb6 100644
---
a/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/PekkoDiscoverySessionProvider.scala
+++
b/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/PekkoDiscoverySessionProvider.scala
@@ -27,7 +27,7 @@ import scala.concurrent.duration.FiniteDuration
import scala.concurrent.{ ExecutionContext, Future }
/**
- * [[https://doc.akka.io/docs/akka/current/discovery/index.html Pekko
Discovery]]
+ * [[https://pekko.apache.org/docs/pekko/current/discovery/index.html Pekko
Discovery]]
* is enabled by setting the `service-discovery.name` in the given
`CassandraSession` config.
*
* Pekko Discovery overwrites the basic.contact-points` from the configuration
with addresses
diff --git a/contributor-advice.md b/contributor-advice.md
index e98422fb2..30dfd104d 100644
--- a/contributor-advice.md
+++ b/contributor-advice.md
@@ -98,7 +98,7 @@ Refrain from using `org.apache.pekko.stream.connectors` as
Config prefix, prefer
### Evolving APIs with binary compatibility
-All Pekko APIs aim to evolve in a binary compatible way within minor versions.
+All Apache Pekko APIs aim to evolve in a binary compatible way within minor
versions.
1. Do not use any default arguments
@@ -106,7 +106,7 @@ All Pekko APIs aim to evolve in a binary compatible way
within minor versions.
1. To generate a case class replacement, consider using [Kaze
Class](https://github.com/ktoso/kaze-class)
-See [Binary Compatibilty
Rules](https://doc.akka.io/docs/akka/current/common/binary-compatibility-rules.html)
in the Akka documentation.
+See [Binary Compatibilty
Rules](https://pekko.apache.org/docs/pekko/current/common/binary-compatibility-rules.html)
in the Apache Pekko documentation.
See [Binary Compatibility for library
authors](https://docs.scala-lang.org/overviews/core/binary-compatibility-for-library-authors.html)
diff --git
a/couchbase/src/main/java/org/apache/pekko/stream/connectors/couchbase/javadsl/DiscoverySupport.java
b/couchbase/src/main/java/org/apache/pekko/stream/connectors/couchbase/javadsl/DiscoverySupport.java
index c27991e19..c8680871d 100644
---
a/couchbase/src/main/java/org/apache/pekko/stream/connectors/couchbase/javadsl/DiscoverySupport.java
+++
b/couchbase/src/main/java/org/apache/pekko/stream/connectors/couchbase/javadsl/DiscoverySupport.java
@@ -22,7 +22,7 @@ import java.util.concurrent.CompletionStage;
/**
* Utility to delegate Couchbase node address lookup to
- * [[https://doc.akka.io/docs/akka/current/discovery/index.html Pekko
Discovery]].
+ * [[https://pekko.apache.org/docs/pekko/current/discovery/index.html Pekko
Discovery]].
*/
public final class DiscoverySupport {
diff --git
a/couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/DiscoverySupport.scala
b/couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/DiscoverySupport.scala
index cf4168c40..dd7184e71 100644
---
a/couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/DiscoverySupport.scala
+++
b/couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/scaladsl/DiscoverySupport.scala
@@ -29,7 +29,7 @@ import scala.concurrent.Future
import scala.concurrent.duration.FiniteDuration
/**
- * Utility to delegate Couchbase node address lookup to
[[https://doc.akka.io/docs/akka/current/discovery/index.html Pekko Discovery]].
+ * Utility to delegate Couchbase node address lookup to
[[https://pekko.apache.org/docs/pekko/current/discovery/index.html Pekko
Discovery]].
*/
sealed class DiscoverySupport private {
@@ -103,7 +103,7 @@ sealed class DiscoverySupport private {
}
/**
- * Utility to delegate Couchbase node address lookup to
[[https://doc.akka.io/docs/akka/current/discovery/index.html Pekko Discovery]].
+ * Utility to delegate Couchbase node address lookup to
[[https://pekko.apache.org/docs/pekko/current/discovery/index.html Pekko
Discovery]].
*/
object DiscoverySupport extends DiscoverySupport {
diff --git
a/csv-bench/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/CsvBench.scala
b/csv-bench/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/CsvBench.scala
index a964c6afc..b661296ee 100644
---
a/csv-bench/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/CsvBench.scala
+++
b/csv-bench/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl/CsvBench.scala
@@ -110,7 +110,7 @@ class CsvBench {
/**
* Compact is important here.
*
- * alpakka-csv perf suffers a bit over non-compact
[[pekko.util.ByteString.ByteStrings]].
+ * pekko-connectors-csv perf suffers a bit over non-compact
[[pekko.util.ByteString.ByteStrings]].
* Its design relies on getting bytes by index from the [[ByteString]].
* The indirections add up.
*
diff --git a/docs/src/main/paradox/.htaccess b/docs/src/main/paradox/.htaccess
deleted file mode 100644
index ed4a1d6f3..000000000
--- a/docs/src/main/paradox/.htaccess
+++ /dev/null
@@ -1,9 +0,0 @@
-# This file can be used for redirects like:
-RedirectMatch 301 ^/docs/alpakka/([^/]+)/data-transformations/recordio.html
https://doc.akka.io/docs/alpakka/$1/data-transformations/simple-codecs.html
-# Move CSV example to alpakka-samples
-RedirectMatch 301 ^/docs/alpakka/([^/]+)/examples/csv-samples.html
https://akka.io/alpakka-samples/
-# Drop pre-1.0 release notes
-RedirectMatch 301 ^/docs/alpakka/([^/]+)/release-notes/1.0-RC1.html
https://doc.akka.io/docs/alpakka/$1/release-notes/1.0.x.html
-RedirectMatch 301 ^/docs/alpakka/([^/]+)/release-notes/1.0-M3.html
https://doc.akka.io/docs/alpakka/$1/release-notes/1.0.x.html
-RedirectMatch 301 ^/docs/alpakka/([^/]+)/release-notes/1.0-M2.html
https://doc.akka.io/docs/alpakka/$1/release-notes/1.0.x.html
-RedirectMatch 301 ^/docs/alpakka/([^/]+)/release-notes/1.0-M1.html
https://doc.akka.io/docs/alpakka/$1/release-notes/1.0.x.html
diff --git a/docs/src/main/paradox/_template/logo.st
b/docs/src/main/paradox/_template/logo.st
deleted file mode 100644
index 38bc44ea0..000000000
--- a/docs/src/main/paradox/_template/logo.st
+++ /dev/null
@@ -1 +0,0 @@
-<a href="https://akka.io";><img class="logo"
src="$page.base$images/akka-alpakka-reverse.svg"/></a>
diff --git a/docs/src/main/paradox/external/grpc.md
b/docs/src/main/paradox/external/grpc.md
index f961c9e07..dda1baeb7 100644
--- a/docs/src/main/paradox/external/grpc.md
+++ b/docs/src/main/paradox/external/grpc.md
@@ -1,8 +1,8 @@
# gRPC
-[gRPC](https://grpc.io/) is a transport mechanism for request/response and
(non-persistent) streaming use cases. See [Why
gRPC?](https://doc.akka.io/docs/pekko-grpc/current/whygrpc.html) for more
information about when to use gRPC as your transport.
+[gRPC](https://grpc.io/) is a transport mechanism for request/response and
(non-persistent) streaming use cases. See [Why
gRPC?](https://pekko.apache.org/docs/pekko-grpc/current/whygrpc.html) for more
information about when to use gRPC as your transport.
## Apache Pekko gRPC
Apache Pekko gRPC provides support for building Reactive Streams-compliant
gRPC servers and clients on top of Apache Pekko Streams.
-Learn more about it in the [Apache Pekko gRPC
documentation](https://doc.akka.io/docs/pekko-grpc/current/).
+Learn more about it in the [Apache Pekko gRPC
documentation](https://pekko.apache.org/docs/pekko-grpc/current/).
diff --git a/docs/src/main/paradox/index.md b/docs/src/main/paradox/index.md
index b073235ab..680ff018c 100644
--- a/docs/src/main/paradox/index.md
+++ b/docs/src/main/paradox/index.md
@@ -1,6 +1,6 @@
# Apache Pekko Connectors Documentation
-The [Apache Pekko Connectors
project](https://doc.akka.io/docs/alpakka/current/) is an open source
initiative to implement stream-aware and reactive integration pipelines for
Java and Scala. It is built on top of @extref:[Apache Pekko
Streams](pekko:stream/index.html), and has been designed from the ground up to
understand streaming natively and provide a DSL for reactive and
stream-oriented programming, with built-in support for backpressure. Apache
Pekko Streams is a [Reactive Streams] [...]
+The [Apache Pekko Connectors
project](https://pekko.apache.org/docs/pekko-connectors/current/) is an open
source initiative to implement stream-aware and reactive integration pipelines
for Java and Scala. It is built on top of @extref:[Apache Pekko
Streams](pekko:stream/index.html), and has been designed from the ground up to
understand streaming natively and provide a DSL for reactive and
stream-oriented programming, with built-in support for backpressure. Apache
Pekko Streams is a [Rea [...]
@@toc { depth=2 }
diff --git a/docs/src/main/paradox/kafka.md b/docs/src/main/paradox/kafka.md
index 025c9ef69..2e07f5643 100644
--- a/docs/src/main/paradox/kafka.md
+++ b/docs/src/main/paradox/kafka.md
@@ -4,4 +4,4 @@ The **Apache Pekko Connectors Kafka connector** (originally
known as **Reactive
## Separate repository
-Please read more about it in the [Apache Pekko Connectors Kafka
documentation](https://doc.akka.io/docs/alpakka-kafka/current/).
+Please read more about it in the [Apache Pekko Connectors Kafka
documentation](https://pekko.apache.org/docs/pekko-connectors-kafka/current/).
diff --git a/docs/src/main/paradox/other-docs/snapshots.md
b/docs/src/main/paradox/other-docs/snapshots.md
index b9612005e..f1169f90f 100644
--- a/docs/src/main/paradox/other-docs/snapshots.md
+++ b/docs/src/main/paradox/other-docs/snapshots.md
@@ -39,7 +39,7 @@ Gradle
## Documentation
-The [snapshot documentation](https://doc.akka.io/docs/alpakka/snapshot/) is
updated with every snapshot build.
+The [snapshot
documentation](https://pekko.apache.org/docs/pekko-connectors/snapshot/) is
updated with every snapshot build.
## Versions
diff --git a/docs/src/main/paradox/overview.md
b/docs/src/main/paradox/overview.md
index ec21a0710..94af30642 100644
--- a/docs/src/main/paradox/overview.md
+++ b/docs/src/main/paradox/overview.md
@@ -1,6 +1,6 @@
# Overview
-The [Apache Pekko Connectors
project](https://doc.akka.io/docs/alpakka/current/) is an open source
initiative to implement stream-aware and reactive integration pipelines for
Java and Scala. It is built on top of @extref:[Apache Pekko
Streams](pekko:stream/index.html), and has been designed from the ground up to
understand streaming natively and provide a DSL for reactive and
stream-oriented programming, with built-in support for backpressure. Apache
Pekko Streams is a [Reactive Streams] [...]
+The [Apache Pekko Connectors
project](https://pekko.apache.org/docs/pekko-connectors/current/) is an open
source initiative to implement stream-aware and reactive integration pipelines
for Java and Scala. It is built on top of @extref:[Apache Pekko
Streams](pekko:stream/index.html), and has been designed from the ground up to
understand streaming natively and provide a DSL for reactive and
stream-oriented programming, with built-in support for backpressure. Apache
Pekko Streams is a [Rea [...]
If you'd like to know what integrations with Apache Pekko Connectors look
like, have a look at our
@ref[self-contained examples](examples/index.md) section.
@@ -12,7 +12,7 @@ There are a few blog posts and presentations about Apache
Pekko Connectors out t
The code in this documentation is compiled against:
-* Apache Pekko Connectors $project.version$
([Github](https://github.com/apache/incubator-pekko-connectors), [API
docs](https://doc.akka.io/api/alpakka/current/org/apache/pekko/stream/connectors/index.html))
+* Apache Pekko Connectors $project.version$
([Github](https://github.com/apache/incubator-pekko-connectors), [API
docs](https://pekko.apache.org/api/pekko-connectors/current/org/apache/pekko/stream/connectors/index.html))
* Scala $scala.binary.version$ (all modules are available for Scala 2.13)
* Apache Pekko Streams $pekko.version$+
(@extref:[Reference](pekko:stream/index.html),
[Github](https://github.com/apache/incubator-pekko))
* Apache Pekko HTTP $pekko-http.version$+ (@extref:[Reference](pekko-http:),
[Github](https://github.com/apache/incubator-pekko-http))
@@ -27,13 +27,13 @@ If you want to try out a connector that has not yet been
released, give @ref[sna
Please feel free to contribute to Apache Pekko Connectors by reporting issues
you identify, or by suggesting changes to the code. Please refer to our
[contributing
instructions](https://github.com/apache/incubator-pekko-connectors/blob/main/CONTRIBUTING.md)
and our [contributor
advice](https://github.com/apache/incubator-pekko-connectors/blob/main/contributor-advice.md)
to learn how it can be done. The target structure for Apache Pekko Connectors
connectors is illustrated by the @ref[Ref [...]
-We want Apache Pekko and Apache Pekko Connectors to strive in a welcoming and
open atmosphere and expect all contributors to respect our [code of
conduct](https://www.lightbend.com/conduct).
+We want Apache Pekko and Apache Pekko Connectors to strive in a welcoming and
open atmosphere and expect all contributors to respect our [code of
conduct](https://www.apache.org/foundation/policies/conduct.html).
-[![alpakka]][alpakka-scaladex] Feel free to tag your project with
*pekko-streams* keyword in Scaladex for easier discoverability.
+[![pekko-connectors]][pekko-connectors-scaladex] Feel free to tag your project
with *pekko-connectors* keyword in Scaladex for easier discoverability.
-[alpakka]:
https://index.scala-lang.org/count.svg?q=topics:pekko-streams&subject=pekko-streams&style=flat-square
+[pekko-connectors]:
https://index.scala-lang.org/count.svg?q=topics:pekko-streams&subject=pekko-connectors&style=flat-square
-[alpakka-scaladex]: https://index.scala-lang.org/search?q=topics:pekko-streams
+[pekko-connectors-scaladex]:
https://index.scala-lang.org/search?q=topics:pekko-connectors
@@ toc { .main depth=2 }
diff --git a/docs/src/main/paradox/release-notes/index.md
b/docs/src/main/paradox/release-notes/index.md
index fc28616c3..b9f65ac1b 100644
--- a/docs/src/main/paradox/release-notes/index.md
+++ b/docs/src/main/paradox/release-notes/index.md
@@ -4,4 +4,4 @@ To understand the forces on version numbers, read about
@ref:[Apache Pekko Conne
@@toc { depth=2 }
-* [Apache Pekko Connectors Release
Notes](https://doc.akka.io/docs/alpakka/current/release-notes/index.html)
+* [Alpakka Release
Notes](https://doc.akka.io/docs/alpakka/current/release-notes/index.html)
diff --git a/dynamodb/src/test/java/docs/javadsl/ExampleTest.java
b/dynamodb/src/test/java/docs/javadsl/ExampleTest.java
index 614df74f0..2d0312643 100644
--- a/dynamodb/src/test/java/docs/javadsl/ExampleTest.java
+++ b/dynamodb/src/test/java/docs/javadsl/ExampleTest.java
@@ -60,7 +60,7 @@ public class ExampleTest {
final ActorSystem system = ActorSystem.create();
// Don't encode credentials in your source code!
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
StaticCredentialsProvider credentialsProvider =
StaticCredentialsProvider.create(AwsBasicCredentials.create("x", "x"));
final DynamoDbAsyncClient client =
@@ -69,7 +69,7 @@ public class ExampleTest {
.region(Region.AWS_GLOBAL)
.httpClient(PekkoHttpClient.builder().withActorSystem(system).build())
// Possibility to configure the retry policy
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
// .overrideConfiguration(...)
// #init-client
.endpointOverride(new URI("http://localhost:8001/";))
diff --git a/dynamodb/src/test/scala/docs/scaladsl/ExampleSpec.scala
b/dynamodb/src/test/scala/docs/scaladsl/ExampleSpec.scala
index c81dd3fbe..8de886ca8 100644
--- a/dynamodb/src/test/scala/docs/scaladsl/ExampleSpec.scala
+++ b/dynamodb/src/test/scala/docs/scaladsl/ExampleSpec.scala
@@ -60,7 +60,7 @@ class ExampleSpec
// #init-client
// Don't encode credentials in your source code!
- // see https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
private val credentialsProvider =
StaticCredentialsProvider.create(AwsBasicCredentials.create("x", "x"))
implicit val client: DynamoDbAsyncClient = DynamoDbAsyncClient
.builder()
@@ -68,7 +68,7 @@ class ExampleSpec
.credentialsProvider(credentialsProvider)
.httpClient(PekkoHttpClient.builder().withActorSystem(system).build())
// Possibility to configure the retry policy
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
// .overrideConfiguration(...)
// #init-client
.endpointOverride(new URI("http://localhost:8001/";))
diff --git a/file/src/test/java/docs/javadsl/ArchiveTest.java
b/file/src/test/java/docs/javadsl/ArchiveTest.java
index 64f9e6dce..fb06405bd 100644
--- a/file/src/test/java/docs/javadsl/ArchiveTest.java
+++ b/file/src/test/java/docs/javadsl/ArchiveTest.java
@@ -116,7 +116,7 @@ public class ArchiveTest {
Map<String, ByteString> unzip = archiveHelper.unzip(resultFileContent);
assertThat(inputFiles, is(unzip));
- Path target = Files.createTempDirectory("alpakka-zip-");
+ Path target = Files.createTempDirectory("pekko-connectors-zip-");
// #sample-zip-read
Archive.zipReader(Paths.get("logo.zip").toFile())
@@ -215,7 +215,7 @@ public class ArchiveTest {
Source<ByteString, NotUsed> bytesSource = // ???
// #tar-reader
Source.completionStage(oneFileArchive);
- Path target = Files.createTempDirectory("alpakka-tar-");
+ Path target = Files.createTempDirectory("pekko-connectors-tar-");
// #tar-reader
CompletionStage<Done> tar =
@@ -263,7 +263,7 @@ public class ArchiveTest {
.runWith(Sink.fold(ByteString.emptyByteString(),
ByteString::concat), system);
Source<ByteString, NotUsed> bytesSource =
Source.completionStage(oneFileArchive);
- Path target = Files.createTempDirectory("alpakka-tar-");
+ Path target = Files.createTempDirectory("pekko-connectors-tar-");
CompletionStage<Done> tar =
bytesSource
diff --git a/file/src/test/java/docs/javadsl/NestedTarReaderTest.java
b/file/src/test/java/docs/javadsl/NestedTarReaderTest.java
index 8bd8594da..0f540335e 100644
--- a/file/src/test/java/docs/javadsl/NestedTarReaderTest.java
+++ b/file/src/test/java/docs/javadsl/NestedTarReaderTest.java
@@ -63,7 +63,7 @@ public class NestedTarReaderTest {
@Test
public void flowShouldCreateZIPArchive() throws Exception {
- Path tempDir = Files.createTempDirectory("alpakka-ftp");
+ Path tempDir = Files.createTempDirectory("pekko-connectors-ftp");
tempDir.toFile().deleteOnExit();
Path file = Paths.get("./file/src/test/resources/nested-sample.tar");
logger.info(
diff --git a/file/src/test/scala/docs/scaladsl/ArchiveSpec.scala
b/file/src/test/scala/docs/scaladsl/ArchiveSpec.scala
index ea6c9edce..9708d436b 100644
--- a/file/src/test/scala/docs/scaladsl/ArchiveSpec.scala
+++ b/file/src/test/scala/docs/scaladsl/ArchiveSpec.scala
@@ -148,7 +148,7 @@ class ArchiveSpec
// #zip-reader
val target: Path = // ???
// #zip-reader
- Files.createTempDirectory("alpakka-zip-")
+ Files.createTempDirectory("pekko-connectors-zip-")
// #zip-reader
Archive
.zipReader(zipFile)
diff --git a/file/src/test/scala/docs/scaladsl/TarArchiveSpec.scala
b/file/src/test/scala/docs/scaladsl/TarArchiveSpec.scala
index 4577519af..b94740068 100644
--- a/file/src/test/scala/docs/scaladsl/TarArchiveSpec.scala
+++ b/file/src/test/scala/docs/scaladsl/TarArchiveSpec.scala
@@ -176,7 +176,7 @@ class TarArchiveSpec
val bytesSource: Source[ByteString, NotUsed] = // ???
// #tar-reader
Source.future(oneFileArchive)
- val target = Files.createTempDirectory("alpakka-tar-")
+ val target = Files.createTempDirectory("pekko-connectors-tar-")
// #tar-reader
val tar =
diff --git
a/ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/BaseSupportImpl.java
b/ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/BaseSupportImpl.java
index 9c7e17a70..7da08ed80 100644
---
a/ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/BaseSupportImpl.java
+++
b/ftp/src/test/java/org/apache/pekko/stream/connectors/ftp/BaseSupportImpl.java
@@ -24,7 +24,7 @@ import java.nio.file.attribute.BasicFileAttributes;
public abstract class BaseSupportImpl implements BaseSupport, PekkoSupport {
- private ActorSystem system = ActorSystem.create("alpakka-ftp");
+ private ActorSystem system = ActorSystem.create("pekko-connectors-ftp");
private Materializer materializer = Materializer.matFromSystem(system);
public final FtpCredentials CREDENTIALS = FtpCredentials.create("username",
"userpass");
public final FtpCredentials WRONG_CREDENTIALS =
FtpCredentials.create("username", "qwerty");
diff --git a/google-cloud-bigquery-storage/src/main/resources/reference.conf
b/google-cloud-bigquery-storage/src/main/resources/reference.conf
index 50270e376..9494f71ae 100644
--- a/google-cloud-bigquery-storage/src/main/resources/reference.conf
+++ b/google-cloud-bigquery-storage/src/main/resources/reference.conf
@@ -7,7 +7,7 @@ pekko.connectors.google {
credentials {
provider = none
none {
- project-id = "alpakka-google-test"
+ project-id = "pekko-connectors-google-test"
token = "yyyy.c.an-access-token"
}
}
diff --git
a/google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/BigQueryStorageSpecBase.scala
b/google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/BigQueryStorageSpecBase.scala
index efb864a00..41b139345 100644
---
a/google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/BigQueryStorageSpecBase.scala
+++
b/google-cloud-bigquery-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/BigQueryStorageSpecBase.scala
@@ -32,7 +32,7 @@ abstract class BigQueryStorageSpecBase(_port: Int) extends
BigQueryMockData with
private[bigquery] val bqHost = "localhost"
private[bigquery] val bqPort = _port
- implicit val system: ActorSystem = ActorSystem("alpakka-bigquery-storage")
+ implicit val system: ActorSystem =
ActorSystem("pekko-connectors-bigquery-storage")
implicit val defaultPatience: PatienceConfig = PatienceConfig(timeout =
15.seconds, interval = 50.millis)
diff --git a/google-cloud-bigquery/src/test/resources/BigQueryEndToEndSpec.json
b/google-cloud-bigquery/src/test/resources/BigQueryEndToEndSpec.json
index 8c5790a86..10fe52abd 100644
--- a/google-cloud-bigquery/src/test/resources/BigQueryEndToEndSpec.json
+++ b/google-cloud-bigquery/src/test/resources/BigQueryEndToEndSpec.json
@@ -51,7 +51,7 @@
"request" : {
"path" : [ {
"matcher" : "exact",
- "value" : "/bigquery/v2/projects/alpakka-bigquery-test/datasets"
+ "value" :
"/bigquery/v2/projects/pekko-connectors-bigquery-test/datasets"
} ],
"method" : [ {
"matcher" : "exact",
@@ -78,7 +78,7 @@
},
"response" : {
"status" : 200,
- "body" :
"{\"kind\":\"bigquery#dataset\",\"etag\":\"du1yDtDvifCnhuw6UPR11Q==\",\"id\":\"alpakka-bigquery-test:e2e_dataset_677\",\"selfLink\":\"https://bigquery.googleapis.com/bigquery/v2/projects/alpakka-bigquery-test/datasets/e2e_dataset_677\",\"datasetReference\":{\"datasetId\":\"e2e_dataset_677\",\"projectId\":\"alpakka-bigquery-test\"},\"defaultTableExpirationMs\":\"5184000000\",\"access\":[{\"role\":\"WRITER\",\"specialGroup\":\"projectWriters\"},{\"role\":\"OWNER\",\"specia
[...]
+ "body" :
"{\"kind\":\"bigquery#dataset\",\"etag\":\"du1yDtDvifCnhuw6UPR11Q==\",\"id\":\"pekko-connectors-bigquery-test:e2e_dataset_677\",\"selfLink\":\"https://bigquery.googleapis.com/bigquery/v2/projects/pekko-connectors-bigquery-test/datasets/e2e_dataset_677\",\"datasetReference\":{\"datasetId\":\"e2e_dataset_677\",\"projectId\":\"pekko-connectors-bigquery-test\"},\"defaultTableExpirationMs\":\"5184000000\",\"access\":[{\"role\":\"WRITER\",\"specialGroup\":\"projectWriters\"},{
[...]
"encodedBody" : false,
"templated" : false,
"headers" : {
@@ -99,7 +99,7 @@
"request" : {
"path" : [ {
"matcher" : "exact",
- "value" : "/bigquery/v2/projects/alpakka-bigquery-test/datasets"
+ "value" :
"/bigquery/v2/projects/pekko-connectors-bigquery-test/datasets"
} ],
"method" : [ {
"matcher" : "exact",
@@ -129,7 +129,7 @@
},
"response" : {
"status" : 200,
- "body" :
"{\"kind\":\"bigquery#datasetList\",\"etag\":\"IHoKkRKhcfVOeVouhHW+8Q==\",\"datasets\":[{\"kind\":\"bigquery#dataset\",\"id\":\"alpakka-bigquery-test:client_test_dataset\",\"datasetReference\":{\"datasetId\":\"client_test_dataset\",\"projectId\":\"alpakka-bigquery-test\"},\"location\":\"US\"},{\"kind\":\"bigquery#dataset\",\"id\":\"alpakka-bigquery-test:e2e_dataset_677\",\"datasetReference\":{\"datasetId\":\"e2e_dataset_677\",\"projectId\":\"alpakka-bigquery-test\"},\"lo
[...]
+ "body" :
"{\"kind\":\"bigquery#datasetList\",\"etag\":\"IHoKkRKhcfVOeVouhHW+8Q==\",\"datasets\":[{\"kind\":\"bigquery#dataset\",\"id\":\"pekko-connectors-bigquery-test:client_test_dataset\",\"datasetReference\":{\"datasetId\":\"client_test_dataset\",\"projectId\":\"pekko-connectors-bigquery-test\"},\"location\":\"US\"},{\"kind\":\"bigquery#dataset\",\"id\":\"pekko-connectors-bigquery-test:e2e_dataset_677\",\"datasetReference\":{\"datasetId\":\"e2e_dataset_677\",\"projectId\":\"pe
[...]
"encodedBody" : false,
"templated" : false,
"headers" : {
@@ -153,7 +153,7 @@
"request" : {
"path" : [ {
"matcher" : "exact",
- "value" :
"/bigquery/v2/projects/alpakka-bigquery-test/datasets/e2e_dataset_677/tables"
+ "value" :
"/bigquery/v2/projects/pekko-connectors-bigquery-test/datasets/e2e_dataset_677/tables"
} ],
"method" : [ {
"matcher" : "exact",
@@ -180,7 +180,7 @@
},
"response" : {
"status" : 200,
- "body" :
"{\"kind\":\"bigquery#table\",\"etag\":\"vmr9T2MpeU+X3ofY2WycsA==\",\"id\":\"alpakka-bigquery-test:e2e_dataset_677.e2e_table_242\",\"selfLink\":\"https://bigquery.googleapis.com/bigquery/v2/projects/alpakka-bigquery-test/datasets/e2e_dataset_677/tables/e2e_table_242\",\"tableReference\":{\"projectId\":\"alpakka-bigquery-test\",\"datasetId\":\"e2e_dataset_677\",\"tableId\":\"e2e_table_242\"},\"schema\":{\"fields\":[{\"name\":\"integer\",\"type\":\"INTEGER\",\"mode\":\"REQ
[...]
+ "body" :
"{\"kind\":\"bigquery#table\",\"etag\":\"vmr9T2MpeU+X3ofY2WycsA==\",\"id\":\"pekko-connectors-bigquery-test:e2e_dataset_677.e2e_table_242\",\"selfLink\":\"https://bigquery.googleapis.com/bigquery/v2/projects/pekko-connectors-bigquery-test/datasets/e2e_dataset_677/tables/e2e_table_242\",\"tableReference\":{\"projectId\":\"pekko-connectors-bigquery-test\",\"datasetId\":\"e2e_dataset_677\",\"tableId\":\"e2e_table_242\"},\"schema\":{\"fields\":[{\"name\":\"integer\",\"type\";
[...]
"encodedBody" : false,
"templated" : false,
"headers" : {
@@ -201,7 +201,7 @@
"request" : {
"path" : [ {
"matcher" : "exact",
- "value" :
"/bigquery/v2/projects/alpakka-bigquery-test/datasets/e2e_dataset_677/tables"
+ "value" :
"/bigquery/v2/projects/pekko-connectors-bigquery-test/datasets/e2e_dataset_677/tables"
} ],
"method" : [ {
"matcher" : "exact",
@@ -231,7 +231,7 @@
},
"response" : {
"status" : 200,
- "body" :
"{\"kind\":\"bigquery#tableList\",\"etag\":\"KtseGC/wYnp8bh+imEbRnw==\",\"tables\":[{\"kind\":\"bigquery#table\",\"id\":\"alpakka-bigquery-test:e2e_dataset_677.e2e_table_242\",\"tableReference\":{\"projectId\":\"alpakka-bigquery-test\",\"datasetId\":\"e2e_dataset_677\",\"tableId\":\"e2e_table_242\"},\"type\":\"TABLE\",\"creationTime\":\"1615364092415\",\"expirationTime\":\"1620548092415\"}],\"totalItems\":1}",
+ "body" :
"{\"kind\":\"bigquery#tableList\",\"etag\":\"KtseGC/wYnp8bh+imEbRnw==\",\"tables\":[{\"kind\":\"bigquery#table\",\"id\":\"pekko-connectors-bigquery-test:e2e_dataset_677.e2e_table_242\",\"tableReference\":{\"projectId\":\"pekko-connectors-bigquery-test\",\"datasetId\":\"e2e_dataset_677\",\"tableId\":\"e2e_table_242\"},\"type\":\"TABLE\",\"creationTime\":\"1615364092415\",\"expirationTime\":\"1620548092415\"}],\"totalItems\":1}",
"encodedBody" : false,
"templated" : false,
"headers" : {
@@ -255,7 +255,7 @@
"request" : {
"path" : [ {
"matcher" : "exact",
- "value" : "/upload/bigquery/v2/projects/alpakka-bigquery-test/jobs"
+ "value" :
"/upload/bigquery/v2/projects/pekko-connectors-bigquery-test/jobs"
} ],
"method" : [ {
"matcher" : "exact",
@@ -281,7 +281,7 @@
},
"body" : [ {
"matcher" : "json",
- "value" :
"{\"configuration\":{\"load\":{\"createDisposition\":\"CREATE_NEVER\",\"destinationTable\":{\"datasetId\":\"e2e_dataset_677\",\"projectId\":\"alpakka-bigquery-test\",\"tableId\":\"e2e_table_242\"},\"sourceFormat\":\"NEWLINE_DELIMITED_JSON\",\"writeDisposition\":\"WRITE_APPEND\"}}}"
+ "value" :
"{\"configuration\":{\"load\":{\"createDisposition\":\"CREATE_NEVER\",\"destinationTable\":{\"datasetId\":\"e2e_dataset_677\",\"projectId\":\"pekko-connectors-bigquery-test\",\"tableId\":\"e2e_table_242\"},\"sourceFormat\":\"NEWLINE_DELIMITED_JSON\",\"writeDisposition\":\"WRITE_APPEND\"}}}"
} ],
"headers" : {
"X-Upload-Content-Type" : [ {
@@ -301,7 +301,7 @@
"Date" : [ "Wed, 10 Mar 2021 08:14:53 GMT" ],
"Etag" : [ "FGxPd9GxDTOMCujboHC0Tg==" ],
"Hoverfly" : [ "Was-Here" ],
- "Location" : [
"https://bigquery.googleapis.com/upload/bigquery/v2/projects/alpakka-bigquery-test/jobs?uploadType=resumable&prettyPrint=false&upload_id=ABg5-Uw9oLNBNH0Vg1-cZbvHnoB1FNiK-NtCf6jhtNaJKOOV98gC4LiMuvP-D2tD3m9AG_0MnXT7iXXdhOn6inq8W2i3nzRWZg";
],
+ "Location" : [
"https://bigquery.googleapis.com/upload/bigquery/v2/projects/pekko-connectors-bigquery-test/jobs?uploadType=resumable&prettyPrint=false&upload_id=ABg5-Uw9oLNBNH0Vg1-cZbvHnoB1FNiK-NtCf6jhtNaJKOOV98gC4LiMuvP-D2tD3m9AG_0MnXT7iXXdhOn6inq8W2i3nzRWZg";
],
"Server" : [ "UploadServer" ],
"Vary" : [ "Origin", "X-Origin", "Referer" ],
"X-Guploader-Uploadid" : [
"ABg5-Uw9oLNBNH0Vg1-cZbvHnoB1FNiK-NtCf6jhtNaJKOOV98gC4LiMuvP-D2tD3m9AG_0MnXT7iXXdhOn6inq8W2i3nzRWZg"
]
@@ -311,7 +311,7 @@
"request" : {
"path" : [ {
"matcher" : "exact",
- "value" : "/upload/bigquery/v2/projects/alpakka-bigquery-test/jobs"
+ "value" :
"/upload/bigquery/v2/projects/pekko-connectors-bigquery-test/jobs"
} ],
"method" : [ {
"matcher" : "exact",
@@ -352,7 +352,7 @@
},
"response" : {
"status" : 200,
- "body" :
"{\"kind\":\"bigquery#job\",\"etag\":\"HdtpQIZtVWLI7OXGl0buFA==\",\"id\":\"alpakka-bigquery-test:US.job_lSg_8guJRL-uEqyvK8mDuaXTxvFi\",\"selfLink\":\"https://bigquery.googleapis.com/bigquery/v2/projects/alpakka-bigquery-test/jobs/job_lSg_8guJRL-uEqyvK8mDuaXTxvFi?location=US\",\"user_email\":\"[email protected]\",\"configuration\":{\"load\":{\"schema\":{\"fields\":[{\"name\":\"integer\",\"type\":\"INTEGER\",\"mode\":\"REQUIRED\"},{\
[...]
+ "body" :
"{\"kind\":\"bigquery#job\",\"etag\":\"HdtpQIZtVWLI7OXGl0buFA==\",\"id\":\"pekko-connectors-bigquery-test:US.job_lSg_8guJRL-uEqyvK8mDuaXTxvFi\",\"selfLink\":\"https://bigquery.googleapis.com/bigquery/v2/projects/pekko-connectors-bigquery-test/jobs/job_lSg_8guJRL-uEqyvK8mDuaXTxvFi?location=US\",\"user_email\":\"test-run...@pekko-connectors-bigquery-test.iam.gserviceaccount.com\",\"configuration\":{\"load\":{\"schema\":{\"fields\":[{\"name\":\"integer\",\"type\":\"INTEGER\
[...]
"encodedBody" : false,
"templated" : false,
"headers" : {
@@ -371,7 +371,7 @@
"request" : {
"path" : [ {
"matcher" : "exact",
- "value" :
"/bigquery/v2/projects/alpakka-bigquery-test/jobs/job_lSg_8guJRL-uEqyvK8mDuaXTxvFi"
+ "value" :
"/bigquery/v2/projects/pekko-connectors-bigquery-test/jobs/job_lSg_8guJRL-uEqyvK8mDuaXTxvFi"
} ],
"method" : [ {
"matcher" : "exact",
@@ -401,7 +401,7 @@
},
"response" : {
"status" : 200,
- "body" :
"{\"kind\":\"bigquery#job\",\"etag\":\"rL+9oKCHzU5s3oJfw5GBMA==\",\"id\":\"alpakka-bigquery-test:US.job_lSg_8guJRL-uEqyvK8mDuaXTxvFi\",\"selfLink\":\"https://bigquery.googleapis.com/bigquery/v2/projects/alpakka-bigquery-test/jobs/job_lSg_8guJRL-uEqyvK8mDuaXTxvFi?location=US\",\"user_email\":\"[email protected]\",\"configuration\":{\"load\":{\"schema\":{\"fields\":[{\"name\":\"integer\",\"type\":\"INTEGER\",\"mode\":\"REQUIRED\"},{\
[...]
+ "body" :
"{\"kind\":\"bigquery#job\",\"etag\":\"rL+9oKCHzU5s3oJfw5GBMA==\",\"id\":\"pekko-connectors-bigquery-test:US.job_lSg_8guJRL-uEqyvK8mDuaXTxvFi\",\"selfLink\":\"https://bigquery.googleapis.com/bigquery/v2/projects/pekko-connectors-bigquery-test/jobs/job_lSg_8guJRL-uEqyvK8mDuaXTxvFi?location=US\",\"user_email\":\"test-run...@pekko-connectors-bigquery-test.iam.gserviceaccount.com\",\"configuration\":{\"load\":{\"schema\":{\"fields\":[{\"name\":\"integer\",\"type\":\"INTEGER\
[...]
"encodedBody" : false,
"templated" : false,
"headers" : {
@@ -425,7 +425,7 @@
"request" : {
"path" : [ {
"matcher" : "exact",
- "value" :
"/bigquery/v2/projects/alpakka-bigquery-test/jobs/job_lSg_8guJRL-uEqyvK8mDuaXTxvFi"
+ "value" :
"/bigquery/v2/projects/pekko-connectors-bigquery-test/jobs/job_lSg_8guJRL-uEqyvK8mDuaXTxvFi"
} ],
"method" : [ {
"matcher" : "exact",
@@ -455,7 +455,7 @@
},
"response" : {
"status" : 200,
- "body" :
"{\"kind\":\"bigquery#job\",\"etag\":\"OkvE5QH7WIiJbZZblsfwnQ==\",\"id\":\"alpakka-bigquery-test:US.job_lSg_8guJRL-uEqyvK8mDuaXTxvFi\",\"selfLink\":\"https://bigquery.googleapis.com/bigquery/v2/projects/alpakka-bigquery-test/jobs/job_lSg_8guJRL-uEqyvK8mDuaXTxvFi?location=US\",\"user_email\":\"[email protected]\",\"configuration\":{\"load\":{\"schema\":{\"fields\":[{\"name\":\"integer\",\"type\":\"INTEGER\",\"mode\":\"REQUIRED\"},{\
[...]
+ "body" :
"{\"kind\":\"bigquery#job\",\"etag\":\"OkvE5QH7WIiJbZZblsfwnQ==\",\"id\":\"pekko-connectors-bigquery-test:US.job_lSg_8guJRL-uEqyvK8mDuaXTxvFi\",\"selfLink\":\"https://bigquery.googleapis.com/bigquery/v2/projects/pekko-connectors-bigquery-test/jobs/job_lSg_8guJRL-uEqyvK8mDuaXTxvFi?location=US\",\"user_email\":\"test-run...@pekko-connectors-bigquery-test.iam.gserviceaccount.com\",\"configuration\":{\"load\":{\"schema\":{\"fields\":[{\"name\":\"integer\",\"type\":\"INTEGER\
[...]
"encodedBody" : false,
"templated" : false,
"headers" : {
@@ -476,7 +476,7 @@
"request" : {
"path" : [ {
"matcher" : "exact",
- "value" :
"/bigquery/v2/projects/alpakka-bigquery-test/datasets/e2e_dataset_677/tables/e2e_table_242/data"
+ "value" :
"/bigquery/v2/projects/pekko-connectors-bigquery-test/datasets/e2e_dataset_677/tables/e2e_table_242/data"
} ],
"method" : [ {
"matcher" : "exact",
@@ -523,7 +523,7 @@
"request" : {
"path" : [ {
"matcher" : "exact",
- "value" : "/bigquery/v2/projects/alpakka-bigquery-test/queries"
+ "value" :
"/bigquery/v2/projects/pekko-connectors-bigquery-test/queries"
} ],
"method" : [ {
"matcher" : "exact",
@@ -550,7 +550,7 @@
},
"response" : {
"status" : 200,
- "body" :
"{\"kind\":\"bigquery#queryResponse\",\"schema\":{\"fields\":[{\"name\":\"string\",\"type\":\"STRING\",\"mode\":\"NULLABLE\"},{\"name\":\"record\",\"type\":\"RECORD\",\"mode\":\"NULLABLE\",\"fields\":[{\"name\":\"nullable\",\"type\":\"STRING\",\"mode\":\"NULLABLE\"},{\"name\":\"bytes\",\"type\":\"BYTES\",\"mode\":\"NULLABLE\"},{\"name\":\"repeated\",\"type\":\"RECORD\",\"mode\":\"REPEATED\",\"fields\":[{\"name\":\"numeric\",\"type\":\"NUMERIC\",\"mode\":\"NULLABLE\"},{\"
[...]
+ "body" :
"{\"kind\":\"bigquery#queryResponse\",\"schema\":{\"fields\":[{\"name\":\"string\",\"type\":\"STRING\",\"mode\":\"NULLABLE\"},{\"name\":\"record\",\"type\":\"RECORD\",\"mode\":\"NULLABLE\",\"fields\":[{\"name\":\"nullable\",\"type\":\"STRING\",\"mode\":\"NULLABLE\"},{\"name\":\"bytes\",\"type\":\"BYTES\",\"mode\":\"NULLABLE\"},{\"name\":\"repeated\",\"type\":\"RECORD\",\"mode\":\"REPEATED\",\"fields\":[{\"name\":\"numeric\",\"type\":\"NUMERIC\",\"mode\":\"NULLABLE\"},{\"
[...]
"encodedBody" : false,
"templated" : false,
"headers" : {
@@ -570,7 +570,7 @@
"request" : {
"path" : [ {
"matcher" : "exact",
- "value" : "/bigquery/v2/projects/alpakka-bigquery-test/queries"
+ "value" :
"/bigquery/v2/projects/pekko-connectors-bigquery-test/queries"
} ],
"method" : [ {
"matcher" : "exact",
@@ -597,7 +597,7 @@
},
"response" : {
"status" : 200,
- "body" :
"{\"kind\":\"bigquery#queryResponse\",\"schema\":{\"fields\":[{\"name\":\"string\",\"type\":\"STRING\",\"mode\":\"NULLABLE\"},{\"name\":\"record\",\"type\":\"RECORD\",\"mode\":\"NULLABLE\",\"fields\":[{\"name\":\"nullable\",\"type\":\"STRING\",\"mode\":\"NULLABLE\"},{\"name\":\"bytes\",\"type\":\"BYTES\",\"mode\":\"NULLABLE\"},{\"name\":\"repeated\",\"type\":\"RECORD\",\"mode\":\"REPEATED\",\"fields\":[{\"name\":\"numeric\",\"type\":\"NUMERIC\",\"mode\":\"NULLABLE\"},{\"
[...]
+ "body" :
"{\"kind\":\"bigquery#queryResponse\",\"schema\":{\"fields\":[{\"name\":\"string\",\"type\":\"STRING\",\"mode\":\"NULLABLE\"},{\"name\":\"record\",\"type\":\"RECORD\",\"mode\":\"NULLABLE\",\"fields\":[{\"name\":\"nullable\",\"type\":\"STRING\",\"mode\":\"NULLABLE\"},{\"name\":\"bytes\",\"type\":\"BYTES\",\"mode\":\"NULLABLE\"},{\"name\":\"repeated\",\"type\":\"RECORD\",\"mode\":\"REPEATED\",\"fields\":[{\"name\":\"numeric\",\"type\":\"NUMERIC\",\"mode\":\"NULLABLE\"},{\"
[...]
"encodedBody" : false,
"templated" : false,
"headers" : {
@@ -617,7 +617,7 @@
"request" : {
"path" : [ {
"matcher" : "exact",
- "value" :
"/bigquery/v2/projects/alpakka-bigquery-test/datasets/e2e_dataset_677/tables/e2e_table_242"
+ "value" :
"/bigquery/v2/projects/pekko-connectors-bigquery-test/datasets/e2e_dataset_677/tables/e2e_table_242"
} ],
"method" : [ {
"matcher" : "exact",
@@ -664,7 +664,7 @@
"request" : {
"path" : [ {
"matcher" : "exact",
- "value" :
"/bigquery/v2/projects/alpakka-bigquery-test/datasets/e2e_dataset_677/tables"
+ "value" :
"/bigquery/v2/projects/pekko-connectors-bigquery-test/datasets/e2e_dataset_677/tables"
} ],
"method" : [ {
"matcher" : "exact",
@@ -715,7 +715,7 @@
"request" : {
"path" : [ {
"matcher" : "exact",
- "value" :
"/bigquery/v2/projects/alpakka-bigquery-test/datasets/e2e_dataset_677"
+ "value" :
"/bigquery/v2/projects/pekko-connectors-bigquery-test/datasets/e2e_dataset_677"
} ],
"method" : [ {
"matcher" : "exact",
@@ -766,7 +766,7 @@
"request" : {
"path" : [ {
"matcher" : "exact",
- "value" : "/bigquery/v2/projects/alpakka-bigquery-test/datasets"
+ "value" :
"/bigquery/v2/projects/pekko-connectors-bigquery-test/datasets"
} ],
"method" : [ {
"matcher" : "exact",
@@ -796,7 +796,7 @@
},
"response" : {
"status" : 200,
- "body" :
"{\"kind\":\"bigquery#datasetList\",\"etag\":\"FYbqBPwbyPpuMeagefOPlQ==\",\"datasets\":[{\"kind\":\"bigquery#dataset\",\"id\":\"alpakka-bigquery-test:client_test_dataset\",\"datasetReference\":{\"datasetId\":\"client_test_dataset\",\"projectId\":\"alpakka-bigquery-test\"},\"location\":\"US\"},{\"kind\":\"bigquery#dataset\",\"id\":\"alpakka-bigquery-test:example_dataset\",\"datasetReference\":{\"datasetId\":\"example_dataset\",\"projectId\":\"alpakka-bigquery-test\"},\"lo
[...]
+ "body" :
"{\"kind\":\"bigquery#datasetList\",\"etag\":\"FYbqBPwbyPpuMeagefOPlQ==\",\"datasets\":[{\"kind\":\"bigquery#dataset\",\"id\":\"pekko-connectors-bigquery-test:client_test_dataset\",\"datasetReference\":{\"datasetId\":\"client_test_dataset\",\"projectId\":\"pekko-connectors-bigquery-test\"},\"location\":\"US\"},{\"kind\":\"bigquery#dataset\",\"id\":\"pekko-connectors-bigquery-test:example_dataset\",\"datasetReference\":{\"datasetId\":\"example_dataset\",\"projectId\":\"pe
[...]
"encodedBody" : false,
"templated" : false,
"headers" : {
diff --git a/google-cloud-bigquery/src/test/resources/application.conf
b/google-cloud-bigquery/src/test/resources/application.conf
index 481321d9e..67dfb3f75 100644
--- a/google-cloud-bigquery/src/test/resources/application.conf
+++ b/google-cloud-bigquery/src/test/resources/application.conf
@@ -5,8 +5,8 @@ pekko.connectors.google {
credentials {
provider = service-account
service-account {
- project-id = "alpakka-bigquery-test"
- client-email =
"[email protected]"
+ project-id = "pekko-connectors-bigquery-test"
+ client-email =
"test-run...@pekko-connectors-bigquery-test.iam.gserviceaccount.com"
private-key = "-----BEGIN PRIVATE
KEY-----\nMIICdQIBADANBgkqhkiG9w0BAQEFAASCAl8wggJbAgEAAoGBAM0VDk2Ruavg0+Le\nw7RhcwgfSQqbvItcIe2Jr2NBrCYWr+Kdk4bhNVW6W/un55wgP1XwpihPegqEnJ5Z\nN0/c+Fb3m+TVHNHm7PYuTXOn6TYgCzWL80oHhtODbmk0Z+WYpBK1s4N+GVhTW22J\npE0O23XxEh/HBkh8Nr5J/izluMnfAgMBAAECgYBfzvtsn6zHMHSso3d4WKJd5AfC\njfkqffNXvqASVcbv0F+BFi6qr6G0GCkKy2k3lhUguBlX8bFJIqTskS92/vuBBpDY\nzLvotazHh2RIkxvyZoNFz8KuzefU0IkxZ0sWxy2OKogd807ICL1UeDjyjQe5ePe9\nUZl283iZcP1aJaV1mQJBAPtUcUrn5x78PYs9jCMJJ2lmKb
[...]
}
}
diff --git a/google-cloud-storage/src/test/java/docs/javadsl/GCStorageTest.java
b/google-cloud-storage/src/test/java/docs/javadsl/GCStorageTest.java
index 11e3e242d..c07c902e4 100644
--- a/google-cloud-storage/src/test/java/docs/javadsl/GCStorageTest.java
+++ b/google-cloud-storage/src/test/java/docs/javadsl/GCStorageTest.java
@@ -806,7 +806,7 @@ public class GCStorageTest extends GCStorageWiremockBase {
@Test
public void rewriteFile() throws Exception {
- final String rewriteBucketName = "alpakka-rewrite";
+ final String rewriteBucketName = "pekko-connectors-rewrite";
mock().simulate(mockTokenApi(), mockRewrite(rewriteBucketName));
@@ -825,7 +825,7 @@ public class GCStorageTest extends GCStorageWiremockBase {
@Test
public void failWhenRewriteFileFails() throws Exception {
- final String rewriteBucketName = "alpakka-rewrite";
+ final String rewriteBucketName = "pekko-connectors-rewrite";
mock().simulate(mockTokenApi(), mockRewriteFailure(rewriteBucketName));
diff --git
a/google-cloud-storage/src/test/scala/docs/scaladsl/GCStorageSinkSpec.scala
b/google-cloud-storage/src/test/scala/docs/scaladsl/GCStorageSinkSpec.scala
index 6b5aab3bf..2be0699d5 100644
--- a/google-cloud-storage/src/test/scala/docs/scaladsl/GCStorageSinkSpec.scala
+++ b/google-cloud-storage/src/test/scala/docs/scaladsl/GCStorageSinkSpec.scala
@@ -94,7 +94,7 @@ class GCStorageSinkSpec
}
"rewrite file" in {
- val rewriteBucketName = "alpakka-rewrite"
+ val rewriteBucketName = "pekko-connectors-rewrite"
mock.simulate(
mockTokenApi,
@@ -113,7 +113,7 @@ class GCStorageSinkSpec
}
"fail when rewrite file fails" in {
- val rewriteBucketName = "alpakka-rewrite"
+ val rewriteBucketName = "pekko-connectors-rewrite"
mock.simulate(
mockTokenApi,
diff --git
a/google-cloud-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStreamIntegrationSpec.scala
b/google-cloud-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStreamIntegrationSpec.scala
index 5a66db4df..b36b74fcb 100644
---
a/google-cloud-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStreamIntegrationSpec.scala
+++
b/google-cloud-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl/GCStorageStreamIntegrationSpec.scala
@@ -43,7 +43,7 @@ import scala.concurrent.Future
* storage admin (to run the create/delete bucket test)
* - modify test/resources/application.conf
* - create a `alpakka` bucket for testing
- * - create a rewrite `alpakka-rewrite` bucket for testing
+ * - create a rewrite `pekko-connectors-rewrite` bucket for testing
*/
class GCStorageStreamIntegrationSpec
extends AnyWordSpec
@@ -64,7 +64,7 @@ class GCStorageStreamIntegrationSpec
def settings: GCStorageSettings = GCStorageSettings()
def bucket = "alpakka"
- def rewriteBucket = "alpakka-rewrite"
+ def rewriteBucket = "pekko-connectors-rewrite"
def projectId = settings.projectId
def clientEmail = settings.clientEmail
def privateKey = settings.privateKey
diff --git a/google-common/src/test/resources/application.conf
b/google-common/src/test/resources/application.conf
index 5c5714cc8..d2eab0de4 100644
--- a/google-common/src/test/resources/application.conf
+++ b/google-common/src/test/resources/application.conf
@@ -5,7 +5,7 @@ pekko.connectors.google {
credentials {
provider = none
none {
- project-id = "alpakka-google-test"
+ project-id = "pekko-connectors-google-test"
token = "yyyy.c.an-access-token"
}
}
diff --git
a/hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/model.scala
b/hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/model.scala
index 91021deb2..5f17b63f2 100644
--- a/hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/model.scala
+++ b/hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/model.scala
@@ -60,7 +60,7 @@ final class HdfsWritingSettings private (
object HdfsWritingSettings {
private val DefaultFilePathGenerator: FilePathGenerator =
- FilePathGenerator((rc: Long, _: Long) => s"/tmp/alpakka/$rc")
+ FilePathGenerator((rc: Long, _: Long) => s"/tmp/pekko-connectors/$rc")
val default = new HdfsWritingSettings(
overwrite = true,
@@ -139,7 +139,7 @@ sealed abstract class FilePathGenerator extends ((Long,
Long) => Path) {
}
object FilePathGenerator {
- private val DefaultTempDirectory = "/tmp/alpakka-hdfs"
+ private val DefaultTempDirectory = "/tmp/pekko-connectors-hdfs"
/**
* Scala API: creates [[FilePathGenerator]] to rotate output
diff --git a/hdfs/src/test/java/docs/javadsl/HdfsWriterTest.java
b/hdfs/src/test/java/docs/javadsl/HdfsWriterTest.java
index 0e6f8f4db..68c4e99bf 100644
--- a/hdfs/src/test/java/docs/javadsl/HdfsWriterTest.java
+++ b/hdfs/src/test/java/docs/javadsl/HdfsWriterTest.java
@@ -512,7 +512,7 @@ public class HdfsWriterTest {
private static void documentation() {
// #define-generator
BiFunction<Long, Long, String> func =
- (rotationCount, timestamp) -> "/tmp/alpakka/" + rotationCount + "-" +
timestamp;
+ (rotationCount, timestamp) -> "/tmp/pekko-connectors/" + rotationCount
+ "-" + timestamp;
FilePathGenerator pathGenerator = FilePathGenerator.create(func);
// #define-generator
// #define-settings
diff --git a/hdfs/src/test/scala/docs/scaladsl/HdfsReaderSpec.scala
b/hdfs/src/test/scala/docs/scaladsl/HdfsReaderSpec.scala
index 987de7276..1419ea44a 100644
--- a/hdfs/src/test/scala/docs/scaladsl/HdfsReaderSpec.scala
+++ b/hdfs/src/test/scala/docs/scaladsl/HdfsReaderSpec.scala
@@ -40,7 +40,7 @@ class HdfsReaderSpec
with LogCapturing {
private var hdfsCluster: MiniDFSCluster = _
- private val destination = "/tmp/alpakka/"
+ private val destination = "/tmp/pekko-connectors/"
implicit val system: ActorSystem = ActorSystem()
diff --git a/hdfs/src/test/scala/docs/scaladsl/HdfsWriterSpec.scala
b/hdfs/src/test/scala/docs/scaladsl/HdfsWriterSpec.scala
index 154f317f5..7837b2b41 100644
--- a/hdfs/src/test/scala/docs/scaladsl/HdfsWriterSpec.scala
+++ b/hdfs/src/test/scala/docs/scaladsl/HdfsWriterSpec.scala
@@ -42,7 +42,7 @@ class HdfsWriterSpec
with LogCapturing {
private var hdfsCluster: MiniDFSCluster = _
- private val destination = "/tmp/alpakka/"
+ private val destination = "/tmp/pekko-connectors/"
implicit val system: ActorSystem = ActorSystem()
// #init-client
@@ -512,7 +512,7 @@ class HdfsWriterSpec
private def documentation(): HdfsWritingSettings = {
// #define-generator
val pathGenerator =
- FilePathGenerator((rotationCount: Long, timestamp: Long) =>
s"/tmp/alpakka/$rotationCount-$timestamp")
+ FilePathGenerator((rotationCount: Long, timestamp: Long) =>
s"$destination$rotationCount-$timestamp")
// #define-generator
// #define-settings
val settings =
diff --git
a/hdfs/src/test/scala/org/apache/pekko/stream/connectors/hdfs/util/TestUtils.scala
b/hdfs/src/test/scala/org/apache/pekko/stream/connectors/hdfs/util/TestUtils.scala
index c4934f33f..9e68182ea 100644
---
a/hdfs/src/test/scala/org/apache/pekko/stream/connectors/hdfs/util/TestUtils.scala
+++
b/hdfs/src/test/scala/org/apache/pekko/stream/connectors/hdfs/util/TestUtils.scala
@@ -61,7 +61,7 @@ sealed trait TestUtils {
hdfsCluster
}
- def destination = "/tmp/alpakka/"
+ def destination = "/tmp/pekko-connectors/"
def books: Sequence[ByteString]
diff --git a/ironmq/src/test/java/docs/javadsl/IronMqDocsTest.java
b/ironmq/src/test/java/docs/javadsl/IronMqDocsTest.java
index e524eb6b8..b579af49a 100644
--- a/ironmq/src/test/java/docs/javadsl/IronMqDocsTest.java
+++ b/ironmq/src/test/java/docs/javadsl/IronMqDocsTest.java
@@ -70,7 +70,7 @@ public class IronMqDocsTest extends IronMqClientForJava {
@Test
public void atMostOnce() throws Exception {
- String queueName = "alpakka-java";
+ String queueName = "pekko-connectors-java";
Await.result(givenQueue(queueName), awaiting);
CompletionStage<Done> produced =
@@ -92,7 +92,7 @@ public class IronMqDocsTest extends IronMqClientForJava {
@Test
public void atLeastOnce() throws Exception {
- String queueName = "alpakka-java-committing";
+ String queueName = "pekko-connectors-java-committing";
Await.result(givenQueue(queueName), awaiting);
CompletionStage<Done> produced =
diff --git a/jms/src/main/resources/reference.conf
b/jms/src/main/resources/reference.conf
index abacd3128..39ba4d6fc 100644
--- a/jms/src/main/resources/reference.conf
+++ b/jms/src/main/resources/reference.conf
@@ -1,6 +1,6 @@
# SPDX-License-Identifier: Apache-2.0
-# Settings for the Alpakka JMS connector
+# Settings for the Apache Pekko Connectors JMS connector
#
pekko.connectors.jms {
#connection-retry
@@ -51,7 +51,7 @@ pekko.connectors.jms {
# Timeout for acknowledge.
# (Used by TX consumers.)
ack-timeout = 1 second
- # For use with transactions, if true the stream fails if Alpakka rolls
back the transaction
+ # For use with transactions, if true the stream fails if Apache Pekko
Connectors rolls back the transaction
# when `ack-timeout` is hit.
fail-stream-on-ack-timeout = false
# Max interval before sending queued acknowledges back to the broker.
(Used by AckSources.)
diff --git a/kinesis/src/test/java/docs/javadsl/KinesisFirehoseSnippets.java
b/kinesis/src/test/java/docs/javadsl/KinesisFirehoseSnippets.java
index fa4d19ad9..ad7b51db4 100644
--- a/kinesis/src/test/java/docs/javadsl/KinesisFirehoseSnippets.java
+++ b/kinesis/src/test/java/docs/javadsl/KinesisFirehoseSnippets.java
@@ -38,7 +38,7 @@ public class KinesisFirehoseSnippets {
FirehoseAsyncClient.builder()
.httpClient(PekkoHttpClient.builder().withActorSystem(system).build())
// Possibility to configure the retry policy
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
// .overrideConfiguration(...)
.build();
diff --git a/kinesis/src/test/java/docs/javadsl/KinesisSnippets.java
b/kinesis/src/test/java/docs/javadsl/KinesisSnippets.java
index 022db1be3..f5e2bd458 100644
--- a/kinesis/src/test/java/docs/javadsl/KinesisSnippets.java
+++ b/kinesis/src/test/java/docs/javadsl/KinesisSnippets.java
@@ -50,7 +50,7 @@ public class KinesisSnippets {
KinesisAsyncClient.builder()
.httpClient(PekkoHttpClient.builder().withActorSystem(system).build())
// Possibility to configure the retry policy
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
// .overrideConfiguration(...)
.build();
diff --git a/kinesis/src/test/scala/docs/scaladsl/KinesisFirehoseSnippets.scala
b/kinesis/src/test/scala/docs/scaladsl/KinesisFirehoseSnippets.scala
index efab761de..ce4d4aa07 100644
--- a/kinesis/src/test/scala/docs/scaladsl/KinesisFirehoseSnippets.scala
+++ b/kinesis/src/test/scala/docs/scaladsl/KinesisFirehoseSnippets.scala
@@ -34,7 +34,7 @@ object KinesisFirehoseSnippets {
.builder()
.httpClient(PekkoHttpClient.builder().withActorSystem(system).build())
// Possibility to configure the retry policy
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
// .overrideConfiguration(...)
.build()
diff --git a/kinesis/src/test/scala/docs/scaladsl/KinesisSnippets.scala
b/kinesis/src/test/scala/docs/scaladsl/KinesisSnippets.scala
index ce0aaf252..0bcb3a373 100644
--- a/kinesis/src/test/scala/docs/scaladsl/KinesisSnippets.scala
+++ b/kinesis/src/test/scala/docs/scaladsl/KinesisSnippets.scala
@@ -39,7 +39,7 @@ object KinesisSnippets {
.builder()
.httpClient(PekkoHttpClient.builder().withActorSystem(system).build())
// Possibility to configure the retry policy
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
// .overrideConfiguration(...)
.build()
diff --git a/project/Common.scala b/project/Common.scala
index cc1523b18..bfd1d34ca 100644
--- a/project/Common.scala
+++ b/project/Common.scala
@@ -78,7 +78,7 @@ object Common extends AutoPlugin {
s"https://github.com/apache/incubator-pekko-connectors/tree/${branch}€{FILE_PATH_EXT}#L€{FILE_LINE}";
},
"-doc-canonical-base-url",
- "https://doc.akka.io/api/alpakka/current/";),
+ "https://pekko.apache.org/api/pekko-connectorscurrent/";),
Compile / doc / scalacOptions -= "-Werror",
compile / javacOptions ++= Seq(
"-Xlint:cast",
@@ -101,7 +101,8 @@ object Common extends AutoPlugin {
case _ => Seq.empty[String]
}),
autoAPIMappings := true,
- apiURL :=
Some(url(s"https://doc.akka.io/api/alpakka/${version.value}/akka/stream/alpakka/index.html";)),
+ apiURL := Some(url(
+
s"https://pekko.apache.org/api/pekko-connectors/${version.value}/org/apache/pekko/stream/connectors/index.html";)),
// show full stack traces and test case durations
Test / testOptions += Tests.Argument("-oDF"),
// -a Show stack traces and exception class name for AssertionErrors.
diff --git a/project/Dependencies.scala b/project/Dependencies.scala
index dacb0fde2..efe5f2fa7 100644
--- a/project/Dependencies.scala
+++ b/project/Dependencies.scala
@@ -19,16 +19,16 @@ object Dependencies {
val ScalaVersions = Seq(Scala213, Scala212)
val PekkoVersion = "0.0.0+26656-898c6970-SNAPSHOT"
- val AkkaBinaryVersion = "2.6"
+ val PekkoBinaryVersion = "current"
val InfluxDBJavaVersion = "2.15"
val AwsSdk2Version = "2.17.113"
val AwsSpiPekkoHttpVersion = "0.1.0-SNAPSHOT"
// Sync with plugins.sbt
- val PekkoGrpcBinaryVersion = "2.1"
+ val PekkoGrpcBinaryVersion = "current"
val PekkoHttpVersion = "0.0.0+4345-fa1cb9cb-SNAPSHOT"
- val AkkaHttpBinaryVersion = "10.2"
+ val PekkoHttpBinaryVersion = "current"
val ScalaTestVersion = "3.2.11"
val TestContainersScalaTestVersion = "0.40.3"
val mockitoVersion = "4.2.0" // check even
https://github.com/scalatest/scalatestplus-mockito/releases
diff --git a/project/project-info.conf b/project/project-info.conf
index 8a6de25c3..84777180c 100644
--- a/project/project-info.conf
+++ b/project/project-info.conf
@@ -1,9 +1,9 @@
project-info {
version: "current"
labels: "https://github.com/apache/incubator-pekko-connectors/labels/p%3A";
- scaladoc:
"https://doc.akka.io/api/alpakka/"${project-info.version}"/akka/stream/connectors/";
+ scaladoc:
"https://pekko.apache.org/api/pekko-connectors/"${project-info.version}"/org/apache/pekko/stream/connectors/";
shared-info {
- jdk-versions: ["Adopt OpenJDK 8", "Adopt OpenJDK 11"]
+ jdk-versions: ["OpenJDK 8", "OpenJDK 11", "OpenJDK 17"]
snapshots: {
url: "other-docs/snapshots.html"
text: "Snapshots are available"
@@ -25,7 +25,7 @@ project-info {
]
}
amqp: ${project-info.shared-info} {
- title: "Alpakka AMQP"
+ title: "Apache Pekko Connectors AMQP"
jpms-name: "pekko.stream.connectors.amqp"
issues.url: ${project-info.labels}"amqp"
api-docs: [
@@ -36,7 +36,7 @@ project-info {
]
}
avroparquet: ${project-info.shared-info} {
- title: "Alpakka Avro Parquet"
+ title: "Apache Pekko Connectors Avro Parquet"
jpms-name: "pekko.stream.connectors.avroparquet"
issues.url: ${project-info.labels}"avroparquet"
api-docs: [
@@ -47,7 +47,7 @@ project-info {
]
}
aws-event-bridge: ${project-info.shared-info} {
- title: "Alpakka AWS EventBriged"
+ title: "Apache Pekko Connectors AWS EventBriged"
jpms-name: "pekko.stream.connectors.aws.eventbrigde"
issues.url: ${project-info.labels}"aws-eventbrigde"
api-docs: [
@@ -58,7 +58,7 @@ project-info {
]
}
awslambda: ${project-info.shared-info} {
- title: "Alpakka AWS Lambda"
+ title: "Apache Pekko Connectors AWS Lambda"
jpms-name: "pekko.stream.connectors.aws.lambda"
issues.url: ${project-info.labels}"aws-lambda"
api-docs: [
@@ -69,7 +69,7 @@ project-info {
]
}
azure-storage-queue: ${project-info.shared-info} {
- title: "Alpakka Azure Storage Queue"
+ title: "Apache Pekko Connectors Azure Storage Queue"
jpms-name: "pekko.stream.connectors.azure.storagequeue"
issues.url: ${project-info.labels}"azure-storage-queue"
api-docs: [
@@ -80,7 +80,7 @@ project-info {
]
}
cassandra: ${project-info.shared-info} {
- title: "Alpakka Cassandra"
+ title: "Apache Pekko Connectors Cassandra"
jpms-name: "pekko.stream.connectors.cassandra"
issues.url: ${project-info.labels}"cassandra"
api-docs: [
@@ -91,7 +91,7 @@ project-info {
]
}
couchbase: ${project-info.shared-info} {
- title: "Alpakka Couchbase"
+ title: "Apache Pekko Connectors Couchbase"
jpms-name: "pekko.stream.connectors.couchbase"
issues.url: ${project-info.labels}"couchbase"
api-docs: [
@@ -102,7 +102,7 @@ project-info {
]
}
csv: ${project-info.shared-info} {
- title: "Alpakka CSV"
+ title: "Apache Pekko Connectors CSV"
jpms-name: "pekko.stream.connectors.csv"
issues.url: ${project-info.labels}"csv"
snapshots: {
@@ -116,7 +116,7 @@ project-info {
]
}
dynamodb: ${project-info.shared-info} {
- title: "Alpakka DynamoDB"
+ title: "Apache Pekko Connectors DynamoDB"
jpms-name: "pekko.stream.connectors.aws.dynamodb"
issues.url: ${project-info.labels}"dynamodb"
api-docs: [
@@ -127,7 +127,7 @@ project-info {
]
}
elasticsearch: ${project-info.shared-info} {
- title: "Alpakka Elasticsearch"
+ title: "Apache Pekko Connectors Elasticsearch"
jpms-name: "pekko.stream.connectors.elasticsearch"
issues.url: ${project-info.labels}"elasticsearch"
api-docs: [
@@ -138,7 +138,7 @@ project-info {
]
}
file: ${project-info.shared-info} {
- title: "Alpakka File"
+ title: "Apache Pekko Connectors File"
jpms-name: "pekko.stream.connectors.file"
issues.url: ${project-info.labels}"file"
api-docs: [
@@ -149,7 +149,7 @@ project-info {
]
}
ftp: ${project-info.shared-info} {
- title: "Alpakka FTP"
+ title: "Apache Pekko Connectors FTP"
jpms-name: "pekko.stream.connectors.ftp"
issues.url: ${project-info.labels}"ftp"
api-docs: [
@@ -160,7 +160,7 @@ project-info {
]
}
geode: ${project-info.shared-info} {
- title: "Alpakka Geode"
+ title: "Apache Pekko Connectors Geode"
jpms-name: "pekko.stream.connectors.geode"
issues.url: ${project-info.labels}"geode"
api-docs: [
@@ -171,7 +171,7 @@ project-info {
]
}
google-common: ${project-info.shared-info} {
- title: "Alpakka Google Common"
+ title: "Apache Pekko Connectors Google Common"
jpms-name: "pekko.stream.connectors.google"
issues.url: ${project-info.labels}"google-common"
api-docs: [
@@ -182,7 +182,7 @@ project-info {
]
}
google-cloud-bigquery: ${project-info.shared-info} {
- title: "Alpakka Google Cloud BigQuery"
+ title: "Apache Pekko Connectors Google Cloud BigQuery"
jpms-name: "pekko.stream.connectors.google.cloud.bigquery"
issues.url: ${project-info.labels}"google-cloud-bigquery"
api-docs: [
@@ -193,7 +193,7 @@ project-info {
]
}
google-cloud-bigquery-storage: ${project-info.shared-info} {
- title: "Alpakka Google Cloud BigQuery Storage"
+ title: "Apache Pekko Connectors Google Cloud BigQuery Storage"
jpms-name: "pekko.stream.connectors.google.cloud.bigquery.storage"
issues.url: ${project-info.labels}"google-cloud-bigquery-storage"
// no ScalaDoc generated to avoid duplicated generated classes problems
(see build.sbt)
@@ -205,7 +205,7 @@ project-info {
// ]
}
google-cloud-pub-sub: ${project-info.shared-info} {
- title: "Alpakka Google Cloud PubSub"
+ title: "Apache Pekko Connectors Google Cloud PubSub"
jpms-name: "pekko.stream.connectors.google.cloud.pubsub"
issues.url: ${project-info.labels}"google-cloud-pub-sub"
api-docs: [
@@ -216,7 +216,7 @@ project-info {
]
}
google-cloud-pub-sub-grpc: ${project-info.shared-info} {
- title: "Alpakka Google Cloud PubSub (gRPC)"
+ title: "Apache Pekko Connectors Google Cloud PubSub (gRPC)"
jpms-name: "pekko.stream.connectors.google.cloud.pubsub.grpc"
issues.url: ${project-info.labels}"google-cloud-pub-sub-grpc"
api-docs: [
@@ -227,7 +227,7 @@ project-info {
]
}
google-cloud-storage: ${project-info.shared-info} {
- title: "Alpakka Google Cloud Storage"
+ title: "Apache Pekko Connectors Google Cloud Storage"
jpms-name: "pekko.stream.connectors.google.cloud.storage"
issues.url: ${project-info.labels}"google-cloud-storage"
api-docs: [
@@ -238,7 +238,7 @@ project-info {
]
}
google-fcm: ${project-info.shared-info} {
- title: "Alpakka Google Firebase Cloud Messaging (FCM)"
+ title: "Apache Pekko Connectors Google Firebase Cloud Messaging (FCM)"
jpms-name: "pekko.stream.connectors.google.firebase.fcm"
issues.url: ${project-info.labels}"google-fcm"
api-docs: [
@@ -249,7 +249,7 @@ project-info {
]
}
hbase: ${project-info.shared-info} {
- title: "Alpakka HBase"
+ title: "Apache Pekko Connectors HBase"
jpms-name: "pekko.stream.connectors.hbase"
issues.url: ${project-info.labels}"hbase"
api-docs: [
@@ -260,7 +260,7 @@ project-info {
]
}
influxdb: ${project-info.shared-info} {
- title: "Alpakka InfluxDB"
+ title: "Apache Pekko Connectors InfluxDB"
jpms-name: "pekko.stream.connectors.influxdb"
issues.url: ${project-info.labels}"influxdb"
api-docs: [
@@ -271,7 +271,7 @@ project-info {
]
}
hdfs: ${project-info.shared-info} {
- title: "Alpakka HDFS"
+ title: "Apache Pekko Connectors HDFS"
jpms-name: "pekko.stream.connectors.hdfs"
issues.url: ${project-info.labels}"hdfs"
api-docs: [
@@ -282,7 +282,7 @@ project-info {
]
}
huawei-push-kit: ${project-info.shared-info} {
- title: "Alpakka Huawei Push Kit"
+ title: "Apache Pekko Connectors Huawei Push Kit"
jpms-name: "pekko.stream.connectors.huawei.pushkit"
issues.url: ${project-info.labels}"huawei-push-kit"
api-docs: [
@@ -293,7 +293,7 @@ project-info {
]
}
ironmq: ${project-info.shared-info} {
- title: "Alpakka IronMQ"
+ title: "Apache Pekko Connectors IronMQ"
jpms-name: "pekko.stream.connectors.ironmq"
issues.url: ${project-info.labels}"ironmq"
api-docs: [
@@ -304,7 +304,7 @@ project-info {
]
}
jms: ${project-info.shared-info} {
- title: "Alpakka JMS"
+ title: "Apache Pekko Connectors JMS"
jpms-name: "pekko.stream.connectors.jms"
issues.url: ${project-info.labels}"jms"
api-docs: [
@@ -315,7 +315,7 @@ project-info {
]
}
json-streaming: ${project-info.shared-info} {
- title: "Alpakka JSON Streaming"
+ title: "Apache Pekko Connectors JSON Streaming"
jpms-name: "pekko.stream.connectors.json.streaming"
issues.url: ${project-info.labels}"json-streaming"
snapshots: {
@@ -329,7 +329,7 @@ project-info {
]
}
kinesis: ${project-info.shared-info} {
- title: "Alpakka Kinesis"
+ title: "Apache Pekko Connectors Kinesis"
jpms-name: "pekko.stream.connectors.aws.kinesis"
issues.url: ${project-info.labels}"kinesis"
api-docs: [
@@ -340,7 +340,7 @@ project-info {
]
}
kudu: ${project-info.shared-info} {
- title: "Alpakka Kudu"
+ title: "Apache Pekko Connectors Kudu"
jpms-name: "pekko.stream.connectors.kudu"
issues.url: ${project-info.labels}"kudu"
api-docs: [
@@ -351,7 +351,7 @@ project-info {
]
}
mongodb: ${project-info.shared-info} {
- title: "Alpakka MongoDB"
+ title: "Apache Pekko Connectors MongoDB"
jpms-name: "pekko.stream.connectors.mongodb"
issues.url: ${project-info.labels}"mongodb"
api-docs: [
@@ -362,7 +362,7 @@ project-info {
]
}
mqtt: ${project-info.shared-info} {
- title: "Alpakka MQTT"
+ title: "Apache Pekko Connectors MQTT"
jpms-name: "pekko.stream.connectors.mqtt"
issues.url: ${project-info.labels}"mqtt"
api-docs: [
@@ -373,7 +373,7 @@ project-info {
]
}
mqtt-streaming: ${project-info.shared-info} {
- title: "Alpakka MQTT Streaming"
+ title: "Apache Pekko Connectors MQTT Streaming"
jpms-name: "pekko.stream.connectors.mqttStreaming"
issues.url: ${project-info.labels}"mqtt-streaming"
api-docs: [
@@ -384,7 +384,7 @@ project-info {
]
}
orientdb: ${project-info.shared-info} {
- title: "Alpakka OrientDB"
+ title: "Apache Pekko Connectors OrientDB"
jpms-name: "pekko.stream.connectors.orientdb"
issues.url: ${project-info.labels}"orientdb"
api-docs: [
@@ -395,7 +395,7 @@ project-info {
]
}
pravega: ${project-info.shared-info} {
- title: "Alpakka Pravega"
+ title: "Apache Pekko Connectors Pravega"
jpms-name: "pekko.stream.connectors.pravega"
issues.url: ${project-info.labels}"pravega"
api-docs: [
@@ -406,7 +406,7 @@ project-info {
]
}
s3: ${project-info.shared-info} {
- title: "Alpakka Amazon S3"
+ title: "Apache Pekko Connectors Amazon S3"
jpms-name: "pekko.stream.connectors.aws.s3"
issues.url: ${project-info.labels}"aws-s3"
api-docs: [
@@ -417,7 +417,7 @@ project-info {
]
}
simple-codecs: ${project-info.shared-info} {
- title: "Alpakka Simple Codecs (RecordIO)"
+ title: "Apache Pekko Connectors Simple Codecs (RecordIO)"
jpms-name: "pekko.stream.connectors.simplecodecs"
issues.url: ${project-info.labels}"recordio"
snapshots: {
@@ -431,7 +431,7 @@ project-info {
]
}
slick: ${project-info.shared-info} {
- title: "Alpakka Slick/JDBC"
+ title: "Apache Pekko Connectors Slick/JDBC"
jpms-name: "pekko.stream.connectors.slick"
issues.url: ${project-info.labels}"slick"
api-docs: [
@@ -442,7 +442,7 @@ project-info {
]
}
sns: ${project-info.shared-info} {
- title: "Alpakka AWS SNS"
+ title: "Apache Pekko Connectors AWS SNS"
jpms-name: "pekko.stream.connectors.aws.sns"
issues.url: ${project-info.labels}"aws-sns"
api-docs: [
@@ -453,7 +453,7 @@ project-info {
]
}
solr: ${project-info.shared-info} {
- title: "Alpakka Solr"
+ title: "Apache Pekko Connectors Solr"
jpms-name: "pekko.stream.connectors.solr"
issues.url: ${project-info.labels}"solr"
api-docs: [
@@ -464,7 +464,7 @@ project-info {
]
}
spring-web: ${project-info.shared-info} {
- title: "Alpakka Spring Web"
+ title: "Apache Pekko Connectors Spring Web"
jpms-name: "pekko.stream.connectors.spring.web"
issues.url: ${project-info.labels}"spring-web"
api-docs: [
@@ -475,7 +475,7 @@ project-info {
]
}
sqs: ${project-info.shared-info} {
- title: "Alpakka AWS SQS"
+ title: "Apache Pekko Connectors AWS SQS"
jpms-name: "pekko.stream.connectors.aws.sqs"
issues.url: ${project-info.labels}"aws-sqs"
api-docs: [
@@ -486,7 +486,7 @@ project-info {
]
}
sse: ${project-info.shared-info} {
- title: "Alpakka Server-sent events (SSE)"
+ title: "Apache Pekko Connectors Server-sent events (SSE)"
jpms-name: "pekko.stream.connectors.sse"
issues.url: ${project-info.labels}"sse"
api-docs: [
@@ -497,7 +497,7 @@ project-info {
]
}
text: ${project-info.shared-info} {
- title: "Alpakka Text"
+ title: "Apache Pekko Connectors Text"
jpms-name: "pekko.stream.connectors.text"
issues.url: ${project-info.labels}"text"
snapshots: {
@@ -511,7 +511,7 @@ project-info {
]
}
udp: ${project-info.shared-info} {
- title: "Alpakka UDP"
+ title: "Apache Pekko Connectors UDP"
jpms-name: "pekko.stream.connectors.udp"
issues.url: ${project-info.labels}"udp"
api-docs: [
@@ -522,7 +522,7 @@ project-info {
]
}
unix-domain-socket: ${project-info.shared-info} {
- title: "Alpakka Unix Domain Socket"
+ title: "Apache Pekko Connectors Unix Domain Socket"
jpms-name: "pekko.stream.connectors.unixdomainsocket"
issues.url: ${project-info.labels}"unix-domain-socket"
api-docs: [
@@ -533,7 +533,7 @@ project-info {
]
}
xml: ${project-info.shared-info} {
- title: "Alpakka XML"
+ title: "Apache Pekko Connectors XML"
jpms-name: "pekko.stream.connectors.xml"
issues.url: ${project-info.labels}"xml"
snapshots: {
diff --git a/s3/src/main/resources/reference.conf
b/s3/src/main/resources/reference.conf
index 669ae1bc6..8360747f1 100644
--- a/s3/src/main/resources/reference.conf
+++ b/s3/src/main/resources/reference.conf
@@ -87,7 +87,7 @@ pekko.connectors.s3 {
access-style = virtual
# Custom endpoint url, used for alternate s3 implementations
- # To enable virtual-host-style access with Alpakka S3 use the placeholder
`{bucket}` in the URL
+ # To enable virtual-host-style access with Apache Pekko Connectors S3 use
the placeholder `{bucket}` in the URL
# eg. endpoint-url = "http://{bucket}.s3minio.alpakka:9000";
#
# endpoint-url = null
diff --git a/scripts/link-validator.conf b/scripts/link-validator.conf
index 9fb592346..0c3a677dc 100644
--- a/scripts/link-validator.conf
+++ b/scripts/link-validator.conf
@@ -2,17 +2,17 @@
site-link-validator {
root-dir = "./docs/target/site/"
# relative to `root-dir`
- start-file = "docs/alpakka/snapshot/index.html"
+ start-file = "docs/pekko-connectors/snapshot/index.html"
# Resolves URLs with the given prefix as local files instead
link-mappings = [
{
- prefix = "https://doc.akka.io/docs/alpakka/snapshot/";
- replace = "/docs/alpakka/snapshot/"
+ prefix = "https://pekko.apache.org/docs/pekko-connectors/snapshot/";
+ replace = "/docs/pekko-connectors/snapshot/"
}
{
- prefix = "https://doc.akka.io/api/alpakka/snapshot/";
- replace = "/api/alpakka/snapshot/"
+ prefix = "https://pekko.apache.org/api/pekko-connectors/snapshot/";
+ replace = "/api/pekko-connectors/snapshot/"
}
]
diff --git a/slick/src/test/java/docs/javadsl/SlickTest.java
b/slick/src/test/java/docs/javadsl/SlickTest.java
index e9b2526d0..e9cc090ad 100644
--- a/slick/src/test/java/docs/javadsl/SlickTest.java
+++ b/slick/src/test/java/docs/javadsl/SlickTest.java
@@ -50,7 +50,7 @@ import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertThrows;
/**
- * This unit test is run using a local H2 database using
`/tmp/alpakka-slick-h2-test` for temporary
+ * This unit test is run using a local H2 database using
`/tmp/pekko-connectors-slick-h2-test` for temporary
* storage.
*/
public class SlickTest {
diff --git a/slick/src/test/resources/application.conf
b/slick/src/test/resources/application.conf
index 06e21658e..39536f7f0 100644
--- a/slick/src/test/resources/application.conf
+++ b/slick/src/test/resources/application.conf
@@ -8,7 +8,7 @@ pekko {
}
# This database configuration is used for all unit tests.
-# It will create the following file: alpakka-slick-h2-test
+# It will create the following file: pekko-connectors-slick-h2-test
# in the temporary directory.
#config-h2
# Load using SlickSession.forConfig("slick-h2")
@@ -19,7 +19,7 @@ slick-h2 {
dataSourceClass = "slick.jdbc.DriverDataSource"
properties = {
driver = "org.h2.Driver"
- url = "jdbc:h2:"${java.io.tmpdir}"/alpakka-slick-h2-test"
+ url = "jdbc:h2:"${java.io.tmpdir}"/pekko-connectors-slick-h2-test"
}
}
}
diff --git a/slick/src/test/scala/docs/scaladsl/SlickSpec.scala
b/slick/src/test/scala/docs/scaladsl/SlickSpec.scala
index 1d424c7d2..db1e4418b 100644
--- a/slick/src/test/scala/docs/scaladsl/SlickSpec.scala
+++ b/slick/src/test/scala/docs/scaladsl/SlickSpec.scala
@@ -33,7 +33,7 @@ import org.scalatest.wordspec.AnyWordSpec
/**
* This unit test is run using a local H2 database using
- * `/tmp/alpakka-slick-h2-test` for temporary storage.
+ * `/tmp/pekko-connectors-slick-h2-test` for temporary storage.
*/
class SlickSpec
extends AnyWordSpec
diff --git a/sns/src/test/java/docs/javadsl/SnsPublisherTest.java
b/sns/src/test/java/docs/javadsl/SnsPublisherTest.java
index 21bddeb4a..3112dd7cc 100644
--- a/sns/src/test/java/docs/javadsl/SnsPublisherTest.java
+++ b/sns/src/test/java/docs/javadsl/SnsPublisherTest.java
@@ -60,7 +60,7 @@ public class SnsPublisherTest {
snsClient = createSnsClient();
topicArn =
snsClient
-
.createTopic(CreateTopicRequest.builder().name("alpakka-java-topic-1").build())
+
.createTopic(CreateTopicRequest.builder().name("pekko-connectors-java-topic-1").build())
.get()
.topicArn();
}
@@ -78,7 +78,7 @@ public class SnsPublisherTest {
// #init-client
// Don't encode credentials in your source code!
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
StaticCredentialsProvider credentialsProvider =
StaticCredentialsProvider.create(AwsBasicCredentials.create("x", "x"));
final SnsAsyncClient awsSnsClient =
@@ -90,7 +90,7 @@ public class SnsPublisherTest {
.region(Region.EU_CENTRAL_1)
.httpClient(PekkoHttpClient.builder().withActorSystem(system).build())
// Possibility to configure the retry policy
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
// .overrideConfiguration(...)
.build();
diff --git
a/sns/src/test/scala/org/apache/pekko/stream/connectors/sns/IntegrationTestContext.scala
b/sns/src/test/scala/org/apache/pekko/stream/connectors/sns/IntegrationTestContext.scala
index 64d23e2fa..c2a7a2ab9 100644
---
a/sns/src/test/scala/org/apache/pekko/stream/connectors/sns/IntegrationTestContext.scala
+++
b/sns/src/test/scala/org/apache/pekko/stream/connectors/sns/IntegrationTestContext.scala
@@ -42,7 +42,8 @@ trait IntegrationTestContext extends BeforeAndAfterAll with
ScalaFutures {
def createTopic(): String =
snsClient
-
.createTopic(CreateTopicRequest.builder().name(s"alpakka-topic-${topicNumber.incrementAndGet()}").build())
+ .createTopic(
+
CreateTopicRequest.builder().name(s"pekko-connectors-topic-${topicNumber.incrementAndGet()}").build())
.get()
.topicArn()
@@ -69,7 +70,7 @@ trait IntegrationTestContext extends BeforeAndAfterAll with
ScalaFutures {
import software.amazon.awssdk.regions.Region
// Don't encode credentials in your source code!
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
val credentialsProvider =
StaticCredentialsProvider.create(AwsBasicCredentials.create("x", "x"))
implicit val awsSnsClient: SnsAsyncClient =
SnsAsyncClient
@@ -81,7 +82,7 @@ trait IntegrationTestContext extends BeforeAndAfterAll with
ScalaFutures {
.region(Region.EU_CENTRAL_1)
.httpClient(PekkoHttpClient.builder().withActorSystem(system).build())
// Possibility to configure the retry policy
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
// .overrideConfiguration(...)
.build()
diff --git
a/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishFlow.scala
b/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishFlow.scala
index fdab3ad62..24cdc45a9 100644
---
a/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishFlow.scala
+++
b/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishFlow.scala
@@ -52,7 +52,7 @@ object SqsPublishFlow {
/**
* creates a [[pekko.stream.javadsl.Flow Flow]] that groups messages and
publish them in batches to a SQS queue using an
[[software.amazon.awssdk.services.sqs.SqsAsyncClient AmazonSQSAsync]]
- * @see
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin
+ * @see
https://pekko.apache.org/docs/pekko/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin
*/
def grouped(
queueUrl: String,
diff --git
a/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishSink.scala
b/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishSink.scala
index 76db7cb78..022d6eed2 100644
---
a/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishSink.scala
+++
b/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/javadsl/SqsPublishSink.scala
@@ -61,7 +61,7 @@ object SqsPublishSink {
/**
* creates a [[pekko.stream.javadsl.Sink Sink]] that groups strings and
publishes them as messages in batches to a SQS queue using an
[[software.amazon.awssdk.services.sqs.SqsAsyncClient SqsAsyncClient]]
- * @see
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin
+ * @see
https://pekko.apache.org/docs/pekko/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin
*/
def grouped(queueUrl: String,
settings: SqsPublishGroupedSettings,
@@ -70,7 +70,7 @@ object SqsPublishSink {
/**
* creates a [[pekko.stream.javadsl.Sink Sink]] that groups messages and
publishes them in batches to a SQS queue using an
[[software.amazon.awssdk.services.sqs.SqsAsyncClient SqsAsyncClient]]
- * @see
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin
+ * @see
https://pekko.apache.org/docs/pekko/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin
*/
def groupedMessageSink(queueUrl: String,
settings: SqsPublishGroupedSettings,
@@ -82,7 +82,7 @@ object SqsPublishSink {
/**
* creates a [[pekko.stream.javadsl.Sink Sink]] that accepts an iterable of
strings and publish them as messages in batches to a SQS queue using an
[[software.amazon.awssdk.services.sqs.SqsAsyncClient SqsAsyncClient]]
- * @see
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin
+ * @see
https://pekko.apache.org/docs/pekko/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin
*/
def batch[B <: java.lang.Iterable[String]](queueUrl: String,
settings: SqsPublishBatchSettings,
diff --git
a/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishFlow.scala
b/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishFlow.scala
index 6d7a705b7..929e224e3 100644
---
a/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishFlow.scala
+++
b/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishFlow.scala
@@ -67,7 +67,7 @@ object SqsPublishFlow {
/**
* creates a [[pekko.stream.scaladsl.Flow Flow]] that groups messages and
publishes them in batches to a SQS queue using an
[[software.amazon.awssdk.services.sqs.SqsAsyncClient SqsAsyncClient]]
*
- * @see
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin
+ * @see
https://pekko.apache.org/docs/pekko/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin
*/
def grouped(queueUrl: String, settings: SqsPublishGroupedSettings =
SqsPublishGroupedSettings.Defaults)(
implicit sqsClient: SqsAsyncClient): Flow[SendMessageRequest,
SqsPublishResultEntry, NotUsed] =
diff --git
a/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishSink.scala
b/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishSink.scala
index 680b9260b..8c63273e8 100644
---
a/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishSink.scala
+++
b/sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishSink.scala
@@ -41,7 +41,7 @@ object SqsPublishSink {
/**
* creates a [[pekko.stream.scaladsl.Sink Sink]] that groups strings and
publishes them as messages in batches to a SQS queue using an
[[software.amazon.awssdk.services.sqs.SqsAsyncClient SqsAsyncClient]]
*
- * @see
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin
+ * @see
https://pekko.apache.org/docs/pekko/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin
*/
def grouped(queueUrl: String, settings: SqsPublishGroupedSettings =
SqsPublishGroupedSettings.Defaults)(
implicit sqsClient: SqsAsyncClient): Sink[String, Future[Done]] =
@@ -52,7 +52,7 @@ object SqsPublishSink {
/**
* creates a [[pekko.stream.scaladsl.Sink Sink]] that accepts an iterable of
strings and publish them as messages in batches to a SQS queue using an
[[software.amazon.awssdk.services.sqs.SqsAsyncClient SqsAsyncClient]]
*
- * @see
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin
+ * @see
https://pekko.apache.org/docs/pekko/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin
*/
def batch(
queueUrl: String,
@@ -88,7 +88,7 @@ object SqsPublishSink {
/**
* creates a [[pekko.stream.scaladsl.Sink Sink]] that groups messages and
publishes them in batches to a SQS queue using an
[[software.amazon.awssdk.services.sqs.SqsAsyncClient SqsAsyncClient]]
*
- * @see
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin
+ * @see
https://pekko.apache.org/docs/pekko/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin
*/
def groupedMessageSink(
queueUrl: String,
diff --git a/sqs/src/test/java/docs/javadsl/SqsPublishTest.java
b/sqs/src/test/java/docs/javadsl/SqsPublishTest.java
index c3961c705..cf0f66bf2 100644
--- a/sqs/src/test/java/docs/javadsl/SqsPublishTest.java
+++ b/sqs/src/test/java/docs/javadsl/SqsPublishTest.java
@@ -145,13 +145,13 @@ public class SqsPublishTest extends BaseSqsTest {
CompletionStage<SqsPublishResult> done =
// #flow
// for fix SQS queue
-
Source.single(SendMessageRequest.builder().messageBody("alpakka-flow").build())
+
Source.single(SendMessageRequest.builder().messageBody("pekko-connectors-flow").build())
.via(SqsPublishFlow.create(queueUrl, SqsPublishSettings.create(),
sqsClient))
.runWith(Sink.head(), system);
// #flow
SqsPublishResult result = done.toCompletableFuture().get(10,
TimeUnit.SECONDS);
- assertEquals(toMd5("alpakka-flow"), result.result().md5OfMessageBody());
+ assertEquals(toMd5("pekko-connectors-flow"),
result.result().md5OfMessageBody());
List<Message> messages =
sqsClient
@@ -159,7 +159,7 @@ public class SqsPublishTest extends BaseSqsTest {
.get(2, TimeUnit.SECONDS)
.messages();
assertEquals(1, messages.size());
- assertEquals("alpakka-flow", messages.get(0).body());
+ assertEquals("pekko-connectors-flow", messages.get(0).body());
}
@Test
@@ -170,12 +170,12 @@ public class SqsPublishTest extends BaseSqsTest {
// #flow
// for dynamic SQS queues
Source.single(
-
SendMessageRequest.builder().messageBody("alpakka-flow").queueUrl(queueUrl).build())
+
SendMessageRequest.builder().messageBody("pekko-connectors-flow").queueUrl(queueUrl).build())
.via(SqsPublishFlow.create(SqsPublishSettings.create(), sqsClient))
.runWith(Sink.head(), system);
// #flow
SqsPublishResult result = done.toCompletableFuture().get(10,
TimeUnit.SECONDS);
- assertEquals(toMd5("alpakka-flow"), result.result().md5OfMessageBody());
+ assertEquals(toMd5("pekko-connectors-flow"),
result.result().md5OfMessageBody());
List<Message> messages =
sqsClient
@@ -183,7 +183,7 @@ public class SqsPublishTest extends BaseSqsTest {
.get(2, TimeUnit.SECONDS)
.messages();
assertEquals(1, messages.size());
- assertEquals("alpakka-flow", messages.get(0).body());
+ assertEquals("pekko-connectors-flow", messages.get(0).body());
}
@Test
@@ -354,12 +354,12 @@ public class SqsPublishTest extends BaseSqsTest {
final String queueUrl = randomQueueUrl();
CompletionStage<SqsPublishResult> stage =
-
Source.single(SendMessageRequest.builder().messageBody("alpakka-flow").build())
+
Source.single(SendMessageRequest.builder().messageBody("pekko-connectors-flow").build())
.via(SqsPublishFlow.create(queueUrl, SqsPublishSettings.create(),
sqsClient))
.runWith(Sink.head(), system);
SqsPublishResult result = stage.toCompletableFuture().get(10,
TimeUnit.SECONDS);
- assertEquals(toMd5("alpakka-flow"), result.result().md5OfMessageBody());
+ assertEquals(toMd5("pekko-connectors-flow"),
result.result().md5OfMessageBody());
List<Message> messages =
sqsClient
@@ -369,7 +369,7 @@ public class SqsPublishTest extends BaseSqsTest {
.messages();
assertEquals(1, messages.size());
- assertEquals("alpakka-flow", messages.get(0).body());
+ assertEquals("pekko-connectors-flow", messages.get(0).body());
}
private String toMd5(String s) throws Exception {
diff --git a/sqs/src/test/java/docs/javadsl/SqsSourceTest.java
b/sqs/src/test/java/docs/javadsl/SqsSourceTest.java
index e9e3fc34b..686c9cd18 100644
--- a/sqs/src/test/java/docs/javadsl/SqsSourceTest.java
+++ b/sqs/src/test/java/docs/javadsl/SqsSourceTest.java
@@ -57,7 +57,7 @@ public class SqsSourceTest extends BaseSqsTest {
i ->
SendMessageRequest.builder()
.queueUrl(queueUrl)
- .messageBody("alpakka-" + i)
+ .messageBody("pekko-connectors-" + i)
.build())
.grouped(10)
.runWith(SqsPublishSink.batchedMessageSink(queueUrl,
batchSettings, sqsClient), system);
diff --git
a/sqs/src/test/java/org/apache/pekko/stream/connectors/sqs/javadsl/BaseSqsTest.java
b/sqs/src/test/java/org/apache/pekko/stream/connectors/sqs/javadsl/BaseSqsTest.java
index 92f548834..27596159a 100644
---
a/sqs/src/test/java/org/apache/pekko/stream/connectors/sqs/javadsl/BaseSqsTest.java
+++
b/sqs/src/test/java/org/apache/pekko/stream/connectors/sqs/javadsl/BaseSqsTest.java
@@ -77,7 +77,7 @@ public abstract class BaseSqsTest {
private SqsAsyncClient createAsyncClient(String sqsEndpoint) {
// #init-client
// Don't encode credentials in your source code!
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
StaticCredentialsProvider credentialsProvider =
StaticCredentialsProvider.create(AwsBasicCredentials.create("x", "x"));
SqsAsyncClient sqsClient =
@@ -89,7 +89,7 @@ public abstract class BaseSqsTest {
.region(Region.EU_CENTRAL_1)
.httpClient(PekkoHttpClient.builder().withActorSystem(system).build())
// Possibility to configure the retry policy
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
// .overrideConfiguration(...)
.build();
diff --git a/sqs/src/test/scala/docs/scaladsl/SqsAckSpec.scala
b/sqs/src/test/scala/docs/scaladsl/SqsAckSpec.scala
index 53bec2521..b8fe72edf 100644
--- a/sqs/src/test/scala/docs/scaladsl/SqsAckSpec.scala
+++ b/sqs/src/test/scala/docs/scaladsl/SqsAckSpec.scala
@@ -114,7 +114,7 @@ class SqsAckSpec extends AnyFlatSpec with Matchers with
DefaultTestContext with
"AckSink" should "pull and delete message" taggedAs Integration in {
new IntegrationFixture {
- sendMessage("alpakka-2")
+ sendMessage("pekko-connectors-2")
val future =
// #ack
@@ -132,7 +132,7 @@ class SqsAckSpec extends AnyFlatSpec with Matchers with
DefaultTestContext with
it should "pull and delay a message" taggedAs Integration in {
new IntegrationFixture {
- sendMessage("alpakka-3")
+ sendMessage("pekko-connectors-3")
val future =
// #requeue
@@ -150,7 +150,7 @@ class SqsAckSpec extends AnyFlatSpec with Matchers with
DefaultTestContext with
it should "pull and ignore a message" taggedAs Integration in {
new IntegrationFixture {
- sendMessage("alpakka-flow-ack")
+ sendMessage("pekko-connectors-flow-ack")
val future =
// #ignore
@@ -166,7 +166,7 @@ class SqsAckSpec extends AnyFlatSpec with Matchers with
DefaultTestContext with
"AckFlow" should "pull and delete message via flow" taggedAs Integration in {
new IntegrationFixture {
- sendMessage("alpakka-flow-ack")
+ sendMessage("pekko-connectors-flow-ack")
val future =
// #flow-ack
@@ -179,14 +179,14 @@ class SqsAckSpec extends AnyFlatSpec with Matchers with
DefaultTestContext with
val result = future.futureValue
result shouldBe a[SqsDeleteResult]
- result.messageAction.message.body() shouldBe "alpakka-flow-ack"
+ result.messageAction.message.body() shouldBe "pekko-connectors-flow-ack"
verify(awsSqsClient).deleteMessage(any[DeleteMessageRequest])
}
}
it should "pull and ignore a message" taggedAs Integration in {
new IntegrationFixture {
- sendMessage("alpakka-flow-ack")
+ sendMessage("pekko-connectors-flow-ack")
val future =
SqsSource(queueUrl, sqsSourceSettings)
@@ -197,7 +197,7 @@ class SqsAckSpec extends AnyFlatSpec with Matchers with
DefaultTestContext with
val result = future.futureValue
result shouldBe a[SqsIgnoreResult]
- result.messageAction.message.body() shouldBe "alpakka-flow-ack"
+ result.messageAction.message.body() shouldBe "pekko-connectors-flow-ack"
}
}
diff --git a/sqs/src/test/scala/docs/scaladsl/SqsSourceSpec.scala
b/sqs/src/test/scala/docs/scaladsl/SqsSourceSpec.scala
index fb0a6f0d7..950000abb 100644
--- a/sqs/src/test/scala/docs/scaladsl/SqsSourceSpec.scala
+++ b/sqs/src/test/scala/docs/scaladsl/SqsSourceSpec.scala
@@ -291,7 +291,7 @@ class SqsSourceSpec extends AnyFlatSpec with ScalaFutures
with Matchers with Def
yield SendMessageRequest
.builder()
.queueUrl(queueUrl)
- .messageBody(s"alpakka-$i")
+ .messageBody(s"pekko-connectors-$i")
.build()
input.foreach(m => sqsClient.sendMessage(m).get(2, TimeUnit.SECONDS))
diff --git
a/sqs/src/test/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/DefaultTestContext.scala
b/sqs/src/test/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/DefaultTestContext.scala
index 738236e64..a9090e453 100644
---
a/sqs/src/test/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/DefaultTestContext.scala
+++
b/sqs/src/test/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/DefaultTestContext.scala
@@ -88,7 +88,7 @@ trait DefaultTestContext extends Matchers with
BeforeAndAfterAll with ScalaFutur
// #init-client
// Don't encode credentials in your source code!
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
val credentialsProvider =
StaticCredentialsProvider.create(AwsBasicCredentials.create("x", "x"))
implicit val awsSqsClient = SqsAsyncClient
.builder()
@@ -99,7 +99,7 @@ trait DefaultTestContext extends Matchers with
BeforeAndAfterAll with ScalaFutur
.region(Region.EU_CENTRAL_1)
.httpClient(PekkoHttpClient.builder().withActorSystem(system).build())
// Possibility to configure the retry policy
- // see
https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html
+ // see
https://pekko.apache.org/docs/pekko-connectors/current/aws-shared-configuration.html
// .overrideConfiguration(...)
.build()
diff --git
a/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/CapturingAppender.scala
b/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/CapturingAppender.scala
index d1e670568..ddb8e5c47 100644
---
a/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/CapturingAppender.scala
+++
b/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/CapturingAppender.scala
@@ -20,7 +20,7 @@ import ch.qos.logback.core.AppenderBase
import org.slf4j.LoggerFactory
/**
- * See
https://doc.akka.io/docs/akka/current/typed/testing-async.html#silence-logging-output-from-tests
+ * See
https://pekko.apache.org/docs/pekko/current/typed/testing-async.html#silence-logging-output-from-tests
*
* INTERNAL API
*/
@@ -48,7 +48,7 @@ import org.slf4j.LoggerFactory
}
/**
- * See
https://doc.akka.io/docs/akka/current/typed/testing-async.html#silence-logging-output-from-tests
+ * See
https://pekko.apache.org/docs/pekko/current/typed/testing-async.html#silence-logging-output-from-tests
*
* INTERNAL API
*
diff --git
a/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/LogbackUtil.scala
b/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/LogbackUtil.scala
index dfdaec9a2..cc60a8354 100644
---
a/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/LogbackUtil.scala
+++
b/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/LogbackUtil.scala
@@ -20,7 +20,7 @@ import org.slf4j.LoggerFactory
import scala.annotation.tailrec
/**
- * See
https://doc.akka.io/docs/akka/current/typed/testing-async.html#silence-logging-output-from-tests
+ * See
https://pekko.apache.org/docs/pekko/current/typed/testing-async.html#silence-logging-output-from-tests
*
* INTERNAL API
*/
diff --git
a/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/javadsl/LogCapturingJunit4.scala
b/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/javadsl/LogCapturingJunit4.scala
index e40c7d510..ac67c6ff0 100644
---
a/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/javadsl/LogCapturingJunit4.scala
+++
b/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/javadsl/LogCapturingJunit4.scala
@@ -22,7 +22,7 @@ import org.junit.runners.model.Statement
import org.slf4j.LoggerFactory
/**
- * See
https://doc.akka.io/docs/akka/current/typed/testing-async.html#silence-logging-output-from-tests
+ * See
https://pekko.apache.org/docs/pekko/current/typed/testing-async.html#silence-logging-output-from-tests
*
* JUnit `TestRule` to make log lines appear only when the test failed.
*
diff --git
a/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/scaladsl/LogCapturing.scala
b/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/scaladsl/LogCapturing.scala
index 47c4462dc..64000b0b1 100644
---
a/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/scaladsl/LogCapturing.scala
+++
b/testkit/src/main/scala/org/apache/pekko/stream/connectors/testkit/scaladsl/LogCapturing.scala
@@ -23,7 +23,7 @@ import org.slf4j.LoggerFactory
import org.slf4j.MDC
/**
- * See
https://doc.akka.io/docs/akka/current/typed/testing-async.html#silence-logging-output-from-tests
+ * See
https://pekko.apache.org/docs/pekko/current/typed/testing-async.html#silence-logging-output-from-tests
*
* Mixin this trait to a ScalaTest test to make log lines appear only when the
test failed.
*
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
