You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by fa...@apache.org on 2023/05/22 20:43:15 UTC
[incubator-pekko-connectors] branch main updated: more pekko naming (#110)
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 11abb3825 more pekko naming (#110)
11abb3825 is described below
commit 11abb382585bd10af7eb6dd94d121afa74caa61a
Author: PJ Fanning <pj...@users.noreply.github.com>
AuthorDate: Mon May 22 21:43:09 2023 +0100
more pekko naming (#110)
* more pekko naming
* revert some changes due to test failures
---
.../javadsl/CassandraSessionRegistry.scala | 2 +-
.../scaladsl/CassandraSessionRegistry.scala | 2 +-
contributor-advice.md | 2 +-
.../couchbase/CouchbaseSessionRegistry.scala | 2 +-
.../scaladsl/CouchbaseSessionExamplesSpec.scala | 2 +-
.../main/paradox/images/akka-alpakka-reverse.svg | 1 -
docs/src/main/paradox/s3.md | 4 +--
.../connectors/dynamodb/javadsl/DynamoDb.scala | 2 +-
.../connectors/dynamodb/scaladsl/DynamoDb.scala | 2 +-
.../scaladsl/ElasticsearchConnectorBehaviour.scala | 2 +-
.../scaladsl/OpensearchConnectorBehaviour.scala | 2 +-
.../connectors/geode/PekkoPdxSerializer.scala | 2 +-
.../test/scala/docs/scaladsl/GeodeFlowSpec.scala | 2 +-
.../bigquery/storage/impl/AkkaGrpcSettings.scala | 4 +--
.../storage/javadsl/BigQueryArrowStorage.scala | 2 +-
.../storage/javadsl/BigQueryAvroStorage.scala | 2 +-
.../bigquery/storage/javadsl/BigQueryStorage.scala | 2 +-
.../storage/scaladsl/BigQueryArrowStorage.scala | 2 +-
.../storage/scaladsl/BigQueryAvroStorage.scala | 2 +-
.../storage/scaladsl/BigQueryStorage.scala | 2 +-
.../scaladsl/BigQueryStorageAttributes.scala | 2 +-
.../googlecloud/bigquery/BigQueryAttributes.scala | 2 +-
.../pubsub/grpc/javadsl/GooglePubSub.scala | 2 +-
.../pubsub/grpc/javadsl/PubSubAttributes.scala | 2 +-
.../pubsub/grpc/scaladsl/GooglePubSub.scala | 2 +-
.../pubsub/grpc/scaladsl/PubSubAttributes.scala | 2 +-
.../googlecloud/storage/GCStorageAttributes.scala | 2 +-
.../scala/docs/scaladsl/GCStorageSourceSpec.scala | 8 +++---
.../impl/GCStorageStreamIntegrationSpec.scala | 2 +-
.../storage/scaladsl/GCStorageWiremockBase.scala | 10 ++++----
.../connectors/google/GoogleAttributes.scala | 2 +-
.../src/test/java/docs/javadsl/HdfsWriterTest.java | 6 ++---
.../test/scala/docs/scaladsl/HdfsWriterSpec.scala | 6 ++---
.../stream/connectors/hdfs/util/TestUtils.scala | 6 ++---
ironmq/src/test/resources/application.conf | 2 +-
.../connectors/jms/JmsConsumerSettings.scala | 2 +-
.../stream/connectors/kudu/KuduAttributes.scala | 2 +-
kudu/src/test/java/docs/javadsl/KuduTableTest.java | 2 +-
.../test/scala/docs/scaladsl/KuduTableSpec.scala | 2 +-
project/Dependencies.scala | 4 +--
project/TestChanged.scala | 2 +-
.../stream/connectors/reference/Resource.scala | 6 ++---
.../pekko/stream/connectors/s3/S3Attributes.scala | 2 +-
s3/src/test/java/docs/javadsl/S3Test.java | 4 +--
s3/src/test/scala/docs/scaladsl/S3SourceSpec.scala | 4 +--
solr/src/test/java/docs/javadsl/SolrTest.java | 4 +--
solr/src/test/scala/docs/scaladsl/SolrSpec.scala | 6 ++---
sqs/src/test/java/docs/javadsl/SqsPublishTest.java | 12 ++++-----
sqs/src/test/java/docs/javadsl/SqsSourceTest.java | 4 +--
.../test/scala/docs/scaladsl/SqsPublishSpec.scala | 30 +++++++++++-----------
.../test/scala/docs/scaladsl/SqsSourceSpec.scala | 20 +++++++--------
.../sqs/scaladsl/SqsPublishSinkSpec.scala | 4 +--
.../scaladsl/UnixDomainSocket.scala | 2 +-
53 files changed, 105 insertions(+), 106 deletions(-)
diff --git a/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSessionRegistry.scala b/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSessionRegistry.scala
index 4843c8fa8..75093aff3 100644
--- a/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSessionRegistry.scala
+++ b/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/javadsl/CassandraSessionRegistry.scala
@@ -24,7 +24,7 @@ import com.datastax.oss.driver.api.core.CqlSession
/**
* This Cassandra session registry makes it possible to share Cassandra sessions between multiple use sites
- * in the same `ActorSystem` (important for the Cassandra Akka Persistence plugin where it is shared between journal,
+ * in the same `ActorSystem` (important for the Cassandra Pekko Persistence plugin where it is shared between journal,
* query plugin and snapshot plugin)
*/
object CassandraSessionRegistry {
diff --git a/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSessionRegistry.scala b/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSessionRegistry.scala
index c15e6bc24..575bd9f4e 100644
--- a/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSessionRegistry.scala
+++ b/cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra/scaladsl/CassandraSessionRegistry.scala
@@ -29,7 +29,7 @@ import com.typesafe.config.Config
/**
* This Cassandra session registry makes it possible to share Cassandra sessions between multiple use sites
- * in the same `ActorSystem` (important for the Cassandra Akka Persistence plugin where it is shared between journal,
+ * in the same `ActorSystem` (important for the Cassandra Pekko Persistence plugin where it is shared between journal,
* query plugin and snapshot plugin)
*/
object CassandraSessionRegistry extends ExtensionId[CassandraSessionRegistry] with ExtensionIdProvider {
diff --git a/contributor-advice.md b/contributor-advice.md
index 30dfd104d..667ac0c82 100644
--- a/contributor-advice.md
+++ b/contributor-advice.md
@@ -91,7 +91,7 @@ Add `withXxxx` methods to specify certain fields in the settings instance.
In case you see the need to support reading the settings from `Config`, offer a method taking the `Config` instance so
that the user can apply a proper namespace.
-Refrain from using `org.apache.pekko.stream.connectors` as Config prefix, prefer `alpakka` as root namespace.
+Refrain from using `pekko.stream.connectors` as Config prefix, prefer `pekko` as root namespace.
## Implementation details
diff --git a/couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/CouchbaseSessionRegistry.scala b/couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/CouchbaseSessionRegistry.scala
index 866762a21..6918dc35d 100644
--- a/couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/CouchbaseSessionRegistry.scala
+++ b/couchbase/src/main/scala/org/apache/pekko/stream/connectors/couchbase/CouchbaseSessionRegistry.scala
@@ -28,7 +28,7 @@ import scala.concurrent.{ Future, Promise }
/**
* This Couchbase session registry makes it possible to share Couchbase sessions between multiple use sites
- * in the same `ActorSystem` (important for the Couchbase Akka Persistence plugin where it is shared between journal,
+ * in the same `ActorSystem` (important for the Couchbase Pekko Persistence plugin where it is shared between journal,
* query plugin and snapshot plugin)
*/
object CouchbaseSessionRegistry extends ExtensionId[CouchbaseSessionRegistry] with ExtensionIdProvider {
diff --git a/couchbase/src/test/scala/docs/scaladsl/CouchbaseSessionExamplesSpec.scala b/couchbase/src/test/scala/docs/scaladsl/CouchbaseSessionExamplesSpec.scala
index b1a5003b5..c62b10c54 100644
--- a/couchbase/src/test/scala/docs/scaladsl/CouchbaseSessionExamplesSpec.scala
+++ b/couchbase/src/test/scala/docs/scaladsl/CouchbaseSessionExamplesSpec.scala
@@ -45,7 +45,7 @@ class CouchbaseSessionExamplesSpec
// #registry
import com.couchbase.client.java.env.{ CouchbaseEnvironment, DefaultCouchbaseEnvironment }
- // Akka extension (singleton per actor system)
+ // Pekko extension (singleton per actor system)
val registry = CouchbaseSessionRegistry(actorSystem)
// If connecting to more than one Couchbase cluster, the environment should be shared
diff --git a/docs/src/main/paradox/images/akka-alpakka-reverse.svg b/docs/src/main/paradox/images/akka-alpakka-reverse.svg
deleted file mode 100644
index 548378b28..000000000
--- a/docs/src/main/paradox/images/akka-alpakka-reverse.svg
+++ /dev/null
@@ -1 +0,0 @@
-<svg id="Layer_1" data-name="Layer 1" xmlns="http://www.w3.org/2000/svg" viewBox="0 0 658 270"><title>akka-alpakka-reverse</title><g id="akka-alpakka-reverse"><path d="M422.94,211.26v-5h5v26.2c0,2.95.67,4.22,2.55,4.22.53,0,1.14-.07,1.74-.13v3.75a8.43,8.43,0,0,1-3.15.53,6.22,6.22,0,0,1-3.55-.93,6.66,6.66,0,0,1-2.28-4.83c-2.54,4-6.63,6-12.26,6a16.19,16.19,0,0,1-12.13-5.09,18.92,18.92,0,0,1,0-25.52A16.26,16.26,0,0,1,411,205.23C417.05,205.23,421,207.84,422.94,211.26Zm-3,21.37a13.28,13.28,0,0 [...]
\ No newline at end of file
diff --git a/docs/src/main/paradox/s3.md b/docs/src/main/paradox/s3.md
index 9ccdb91d6..ef02678f0 100644
--- a/docs/src/main/paradox/s3.md
+++ b/docs/src/main/paradox/s3.md
@@ -72,10 +72,10 @@ File metadata (@apidoc[ObjectMetadata](org.apache.pekko.stream.connectors.s3.Obj
Here's an example of using this metadata to stream an object back to a client in Apache Pekko Http.
Scala
-: @@snip [snip](/s3/src/test/scala/docs/scaladsl/S3SourceSpec.scala) { #downloadToAkkaHttp }
+: @@snip [snip](/s3/src/test/scala/docs/scaladsl/S3SourceSpec.scala) { #downloadToPekkoHttp }
Java
-: @@snip [snip](/s3/src/test/java/docs/javadsl/S3Test.java) { #downloadToAkkaHttp }
+: @@snip [snip](/s3/src/test/java/docs/javadsl/S3Test.java) { #downloadToPekkoHttp }
## Access object metadata without downloading object from S3
diff --git a/dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/javadsl/DynamoDb.scala b/dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/javadsl/DynamoDb.scala
index 4e59c6b63..b237b0d9d 100644
--- a/dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/javadsl/DynamoDb.scala
+++ b/dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/javadsl/DynamoDb.scala
@@ -29,7 +29,7 @@ import software.amazon.awssdk.services.dynamodb.model.{ DynamoDbRequest, DynamoD
import scala.util.Try
/**
- * Factory of DynamoDb Akka Stream operators.
+ * Factory of DynamoDb Pekko Stream operators.
*/
object DynamoDb {
diff --git a/dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/scaladsl/DynamoDb.scala b/dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/scaladsl/DynamoDb.scala
index ed2023c5d..5e55ba51f 100644
--- a/dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/scaladsl/DynamoDb.scala
+++ b/dynamodb/src/main/scala/org/apache/pekko/stream/connectors/dynamodb/scaladsl/DynamoDb.scala
@@ -28,7 +28,7 @@ import scala.concurrent.Future
import scala.util.{ Failure, Success, Try }
/**
- * Factory of DynamoDb Akka Stream operators.
+ * Factory of DynamoDb Pekko Stream operators.
*/
object DynamoDb {
diff --git a/elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchConnectorBehaviour.scala b/elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchConnectorBehaviour.scala
index e0ec2b552..925632a53 100644
--- a/elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchConnectorBehaviour.scala
+++ b/elasticsearch/src/test/scala/docs/scaladsl/ElasticsearchConnectorBehaviour.scala
@@ -135,7 +135,7 @@ trait ElasticsearchConnectorBehaviour {
"pass through data in `withContext`" in {
val books = immutable.Seq(
"Akka in Action",
- "Alpakka Patterns")
+ "Pekko Connectors Patterns")
val indexName = "sink3-1"
val createBooks = Source(books).zipWithIndex
diff --git a/elasticsearch/src/test/scala/docs/scaladsl/OpensearchConnectorBehaviour.scala b/elasticsearch/src/test/scala/docs/scaladsl/OpensearchConnectorBehaviour.scala
index d17e7b0b6..09e6073f6 100644
--- a/elasticsearch/src/test/scala/docs/scaladsl/OpensearchConnectorBehaviour.scala
+++ b/elasticsearch/src/test/scala/docs/scaladsl/OpensearchConnectorBehaviour.scala
@@ -135,7 +135,7 @@ trait OpensearchConnectorBehaviour {
"pass through data in `withContext`" in {
val books = immutable.Seq(
"Akka in Action",
- "Alpakka Patterns")
+ "Pekko Connectors Patterns")
val indexName = "sink3-1"
val createBooks = Source(books).zipWithIndex
diff --git a/geode/src/main/scala/org/apache/pekko/stream/connectors/geode/PekkoPdxSerializer.scala b/geode/src/main/scala/org/apache/pekko/stream/connectors/geode/PekkoPdxSerializer.scala
index 0e6d8926b..ec612ab9c 100644
--- a/geode/src/main/scala/org/apache/pekko/stream/connectors/geode/PekkoPdxSerializer.scala
+++ b/geode/src/main/scala/org/apache/pekko/stream/connectors/geode/PekkoPdxSerializer.scala
@@ -16,7 +16,7 @@ package org.apache.pekko.stream.connectors.geode
import org.apache.geode.pdx.PdxSerializer
/**
- * Base interface for Geode `PdxSerializer`s in Alpakka Geode.
+ * Base interface for Geode `PdxSerializer`s in Pekko Connectors Geode.
*/
trait PekkoPdxSerializer[V] extends PdxSerializer {
def clazz: Class[V]
diff --git a/geode/src/test/scala/docs/scaladsl/GeodeFlowSpec.scala b/geode/src/test/scala/docs/scaladsl/GeodeFlowSpec.scala
index 466e0d229..662cfb428 100644
--- a/geode/src/test/scala/docs/scaladsl/GeodeFlowSpec.scala
+++ b/geode/src/test/scala/docs/scaladsl/GeodeFlowSpec.scala
@@ -25,7 +25,7 @@ import scala.language.postfixOps
class GeodeFlowSpec extends GeodeBaseSpec {
- "Alpakka geode" should {
+ "Pekko Connectors geode" should {
"create settings" in {
{
val hostname = "localhost"
diff --git a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/impl/AkkaGrpcSettings.scala b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/impl/AkkaGrpcSettings.scala
index 944fb8e25..08a0bc425 100644
--- a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/impl/AkkaGrpcSettings.scala
+++ b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/impl/AkkaGrpcSettings.scala
@@ -78,8 +78,8 @@ import java.util.concurrent.Executor
}
def requestSettings()(implicit system: ClassicActorSystemProvider, config: Config): RequestSettings = {
- val alpakkaConfig = config.getConfig("pekko.connectors.google")
- RequestSettings(alpakkaConfig)
+ val connectorsConfig = config.getConfig("pekko.connectors.google")
+ RequestSettings(connectorsConfig)
}
}
diff --git a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala
index 8f17097d0..a65d51018 100644
--- a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala
+++ b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala
@@ -26,7 +26,7 @@ import com.google.cloud.bigquery.storage.v1.arrow.{ ArrowRecordBatch, ArrowSchem
import java.util.concurrent.CompletionStage
/**
- * Google BigQuery Storage Api Akka Stream operator factory using Arrow Format.
+ * Google BigQuery Storage Api Pekko Stream operator factory using Arrow Format.
*/
object BigQueryArrowStorage {
diff --git a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala
index 609132f41..515760004 100644
--- a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala
+++ b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala
@@ -25,7 +25,7 @@ import com.google.cloud.bigquery.storage.v1.stream.ReadSession.TableReadOptions
import java.util.concurrent.CompletionStage
/**
- * Google BigQuery Storage Api Akka Stream operator factory using Avro Format.
+ * Google BigQuery Storage Api Pekko Stream operator factory using Avro Format.
*/
object BigQueryAvroStorage {
diff --git a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryStorage.scala b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryStorage.scala
index 58c653118..e64914a47 100644
--- a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryStorage.scala
+++ b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryStorage.scala
@@ -31,7 +31,7 @@ import com.google.cloud.bigquery.storage.v1.stream.ReadSession
import java.util.concurrent.CompletionStage
/**
- * Google BigQuery Storage Api Akka Stream operator factory.
+ * Google BigQuery Storage Api Pekko Stream operator factory.
*/
object BigQueryStorage {
diff --git a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryArrowStorage.scala b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryArrowStorage.scala
index 23b9975e6..92cb6bed6 100644
--- a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryArrowStorage.scala
+++ b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryArrowStorage.scala
@@ -28,7 +28,7 @@ import com.google.cloud.bigquery.storage.v1.stream.ReadSession.TableReadOptions
import scala.concurrent.Future
/**
- * Google BigQuery Storage Api Akka Stream operator factory using Arrow Format.
+ * Google BigQuery Storage Api Pekko Stream operator factory using Arrow Format.
*/
object BigQueryArrowStorage {
diff --git a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryAvroStorage.scala b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryAvroStorage.scala
index 2e4a264f4..21247d53c 100644
--- a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryAvroStorage.scala
+++ b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryAvroStorage.scala
@@ -28,7 +28,7 @@ import com.google.cloud.bigquery.storage.v1.stream.ReadSession.TableReadOptions
import scala.concurrent.Future
/**
- * Google BigQuery Storage Api Akka Stream operator factory using Avro Format.
+ * Google BigQuery Storage Api Pekko Stream operator factory using Avro Format.
*/
object BigQueryAvroStorage {
diff --git a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorage.scala b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorage.scala
index c92cc5a00..74894cd7b 100644
--- a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorage.scala
+++ b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorage.scala
@@ -31,7 +31,7 @@ import com.google.cloud.bigquery.storage.v1.stream.{ DataFormat => StreamDataFor
import scala.concurrent.{ ExecutionContextExecutor, Future }
/**
- * Google BigQuery Storage Api Akka Stream operator factory.
+ * Google BigQuery Storage Api Pekko Stream operator factory.
*/
object BigQueryStorage {
diff --git a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorageAttributes.scala b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorageAttributes.scala
index 48a73362e..0e2786d1f 100644
--- a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorageAttributes.scala
+++ b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl/BigQueryStorageAttributes.scala
@@ -19,7 +19,7 @@ import pekko.stream.Attributes
import pekko.stream.Attributes.Attribute
/**
- * Akka Stream attributes that are used when materializing BigQuery Storage stream blueprints.
+ * Pekko Stream attributes that are used when materializing BigQuery Storage stream blueprints.
*/
object BigQueryStorageAttributes {
diff --git a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryAttributes.scala b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryAttributes.scala
index 330f4dd0a..00a742b80 100644
--- a/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryAttributes.scala
+++ b/google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/BigQueryAttributes.scala
@@ -18,7 +18,7 @@ import pekko.stream.Attributes.Attribute
import pekko.stream.{ Attributes, Materializer }
/**
- * Akka Stream [[Attributes]] that are used when materializing BigQuery stream blueprints.
+ * Pekko Stream [[Attributes]] that are used when materializing BigQuery stream blueprints.
*/
object BigQueryAttributes {
diff --git a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala
index ab74d9f28..e5f3015a6 100644
--- a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala
+++ b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/GooglePubSub.scala
@@ -23,7 +23,7 @@ import pekko.{ Done, NotUsed }
import com.google.pubsub.v1._
/**
- * Google Pub/Sub Akka Stream operator factory.
+ * Google Pub/Sub Pekko Stream operator factory.
*/
object GooglePubSub {
diff --git a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/PubSubAttributes.scala b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/PubSubAttributes.scala
index 4959599cd..b67bb4ff5 100644
--- a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/PubSubAttributes.scala
+++ b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/javadsl/PubSubAttributes.scala
@@ -19,7 +19,7 @@ import pekko.stream.Attributes
import pekko.stream.Attributes.Attribute
/**
- * Akka Stream attributes that are used when materializing PubSub stream blueprints.
+ * Pekko Stream attributes that are used when materializing PubSub stream blueprints.
*/
object PubSubAttributes {
diff --git a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GooglePubSub.scala b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GooglePubSub.scala
index d1a36300d..134d8d6c8 100644
--- a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GooglePubSub.scala
+++ b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/GooglePubSub.scala
@@ -25,7 +25,7 @@ import scala.concurrent.duration._
import scala.concurrent.{ Future, Promise }
/**
- * Google Pub/Sub Akka Stream operator factory.
+ * Google Pub/Sub Pekko Stream operator factory.
*/
object GooglePubSub {
diff --git a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/PubSubAttributes.scala b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/PubSubAttributes.scala
index 18179a6ca..74bd9f6f0 100644
--- a/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/PubSubAttributes.scala
+++ b/google-cloud-pub-sub-grpc/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/grpc/scaladsl/PubSubAttributes.scala
@@ -19,7 +19,7 @@ import pekko.stream.Attributes
import pekko.stream.Attributes.Attribute
/**
- * Akka Stream attributes that are used when materializing PubSub stream blueprints.
+ * Pekko Stream attributes that are used when materializing PubSub stream blueprints.
*/
object PubSubAttributes {
diff --git a/google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageAttributes.scala b/google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageAttributes.scala
index ad7497850..064cbfd82 100644
--- a/google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageAttributes.scala
+++ b/google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/GCStorageAttributes.scala
@@ -18,7 +18,7 @@ import pekko.stream.Attributes
import pekko.stream.Attributes.Attribute
/**
- * Akka Stream attributes that are used when materializing GCStorage stream blueprints.
+ * Pekko Stream attributes that are used when materializing GCStorage stream blueprints.
* @deprecated Use [[pekko.stream.connectors.google.GoogleAttributes]]
*/
@deprecated("Use org.apache.pekko.stream.connectors.google.GoogleAttributes", "3.0.0")
diff --git a/google-cloud-storage/src/test/scala/docs/scaladsl/GCStorageSourceSpec.scala b/google-cloud-storage/src/test/scala/docs/scaladsl/GCStorageSourceSpec.scala
index 5bf1f6534..3f1f8aa0b 100644
--- a/google-cloud-storage/src/test/scala/docs/scaladsl/GCStorageSourceSpec.scala
+++ b/google-cloud-storage/src/test/scala/docs/scaladsl/GCStorageSourceSpec.scala
@@ -367,7 +367,7 @@ class GCStorageSourceSpec
}
"download results in None when file doesn't exist" in {
- val bucketName = "alpakka"
+ val bucketName = "connectors"
val fileName = "file1.txt"
mock.simulate(
@@ -380,7 +380,7 @@ class GCStorageSourceSpec
}
"fail with error when file download fails" in {
- val bucketName = "alpakka"
+ val bucketName = "connectors"
val fileName = "file1.txt"
mock.simulate(
@@ -396,7 +396,7 @@ class GCStorageSourceSpec
}
"automatically retry when file downloads fail" in {
- val bucketName = "alpakka"
+ val bucketName = "connectors"
val fileName = "file1.txt"
val fileContent = "This is the file content"
@@ -419,7 +419,7 @@ class GCStorageSourceSpec
// retry for all akka-http standard server errors (5XX) https://github.com/akka/alpakka/issues/2057
"automatically retry when file downloads fail with a non-500 server error" in {
- val bucketName = "alpakka"
+ val bucketName = "connectors"
val fileName = "file1.txt"
val fileContent = "This is the file content"
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 b36b74fcb..d0ee0d8a5 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
@@ -63,7 +63,7 @@ class GCStorageStreamIntegrationSpec
@nowarn("msg=deprecated")
def settings: GCStorageSettings = GCStorageSettings()
- def bucket = "alpakka"
+ def bucket = "connectors"
def rewriteBucket = "pekko-connectors-rewrite"
def projectId = settings.projectId
def clientEmail = settings.clientEmail
diff --git a/google-cloud-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/storage/scaladsl/GCStorageWiremockBase.scala b/google-cloud-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/storage/scaladsl/GCStorageWiremockBase.scala
index ac9ff8220..1679bd7a0 100644
--- a/google-cloud-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/storage/scaladsl/GCStorageWiremockBase.scala
+++ b/google-cloud-storage/src/test/scala/org/apache/pekko/stream/connectors/googlecloud/storage/scaladsl/GCStorageWiremockBase.scala
@@ -44,7 +44,7 @@ abstract class GCStorageWiremockBase(_system: ActorSystem, _wireMockServer: Hove
def stopWireMockServer(): Unit = _wireMockServer.close()
- val bucketName = "alpakka"
+ val bucketName = "connectors"
val fileName = "file1.txt"
val generation = 1543055053992769L
@@ -67,7 +67,7 @@ abstract class GCStorageWiremockBase(_system: ActorSystem, _wireMockServer: Hove
| "contentType":"text/plain; charset=UTF-8",
| "updated":"2018-11-24T10:24:13.992Z",
| "mediaLink":"https://www.googleapis.com/download/storage/v1/b/alpakka/o/$fileName?generation=1543055053992768&alt=media",
- | "bucket":"alpakka",
+ | "bucket":"connectors",
| "kind":"storage#object",
| "metageneration":"1",
| "timeDeleted": "2018-11-24T10:24:13.992Z",
@@ -373,7 +373,7 @@ abstract class GCStorageWiremockBase(_system: ActorSystem, _wireMockServer: Hove
| "contentType":"text/plain; charset=UTF-8",
| "updated":"2018-11-24T10:24:13.992Z",
| "mediaLink":"https://www.googleapis.com/download/storage/v1/b/alpakka/o/$firstFileName?generation=1543055053992768&alt=media",
- | "bucket":"alpakka",
+ | "bucket":"connectors",
| "kind":"storage#object",
| "metageneration":"1",
| "timeDeleted": "2018-11-24T10:24:13.992Z",
@@ -402,7 +402,7 @@ abstract class GCStorageWiremockBase(_system: ActorSystem, _wireMockServer: Hove
| "contentType":"text/plain; charset=UTF-8",
| "updated":"2018-11-24T10:24:13.992Z",
| "mediaLink":"https://www.googleapis.com/download/storage/v1/b/alpakka/o/$firstFileName?generation=1543055053992768&alt=media",
- | "bucket":"alpakka",
+ | "bucket":"connectors",
| "kind":"storage#object",
| "metageneration":"1",
| "timeDeleted": "2018-11-24T10:24:13.992Z",
@@ -443,7 +443,7 @@ abstract class GCStorageWiremockBase(_system: ActorSystem, _wireMockServer: Hove
| "contentType":"text/plain; charset=UTF-8",
| "updated":"2018-11-24T10:24:13.992Z",
| "mediaLink":"https://www.googleapis.com/download/storage/v1/b/alpakka/o/$secondFileName?generation=1543055053992768&alt=media",
- | "bucket":"alpakka",
+ | "bucket":"connectors",
| "kind":"storage#object",
| "metageneration":"1",
| "timeDeleted": "2018-11-24T10:24:13.992Z",
diff --git a/google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleAttributes.scala b/google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleAttributes.scala
index ce5c0ce2f..73e4ea384 100644
--- a/google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleAttributes.scala
+++ b/google-common/src/main/scala/org/apache/pekko/stream/connectors/google/GoogleAttributes.scala
@@ -18,7 +18,7 @@ import pekko.stream.Attributes.Attribute
import pekko.stream.{ Attributes, Materializer }
/**
- * Akka Stream [[Attributes]] that are used when materializing stream blueprints containing Google connectors.
+ * Pekko Stream [[Attributes]] that are used when materializing stream blueprints containing Google connectors.
*/
object GoogleAttributes {
diff --git a/hdfs/src/test/java/docs/javadsl/HdfsWriterTest.java b/hdfs/src/test/java/docs/javadsl/HdfsWriterTest.java
index 68c4e99bf..fa69cbe9a 100644
--- a/hdfs/src/test/java/docs/javadsl/HdfsWriterTest.java
+++ b/hdfs/src/test/java/docs/javadsl/HdfsWriterTest.java
@@ -230,9 +230,9 @@ public class HdfsWriterTest {
// to commit the offset to Kafka
List<KafkaMessage> messagesFromKafka =
Arrays.asList(
- new KafkaMessage(new Book("Akka Concurrency"), new KafkaOffset(0)),
- new KafkaMessage(new Book("Akka in Action"), new KafkaOffset(1)),
- new KafkaMessage(new Book("Effective Akka"), new KafkaOffset(2)),
+ new KafkaMessage(new Book("Pekko Concurrency"), new KafkaOffset(0)),
+ new KafkaMessage(new Book("Pekko in Action"), new KafkaOffset(1)),
+ new KafkaMessage(new Book("Effective Pekko"), new KafkaOffset(2)),
new KafkaMessage(new Book("Learning Scala"), new KafkaOffset(3)),
new KafkaMessage(new Book("Scala Puzzlers"), new KafkaOffset(4)),
new KafkaMessage(new Book("Scala for Spark in Production"), new KafkaOffset(5)));
diff --git a/hdfs/src/test/scala/docs/scaladsl/HdfsWriterSpec.scala b/hdfs/src/test/scala/docs/scaladsl/HdfsWriterSpec.scala
index 7837b2b41..062b6a1f5 100644
--- a/hdfs/src/test/scala/docs/scaladsl/HdfsWriterSpec.scala
+++ b/hdfs/src/test/scala/docs/scaladsl/HdfsWriterSpec.scala
@@ -240,9 +240,9 @@ class HdfsWriterSpec
// After we've written them to HDFS, we want
// to commit the offset to Kafka
val messagesFromKafka = List(
- KafkaMessage(Book("Akka Concurrency"), KafkaOffset(0)),
- KafkaMessage(Book("Akka in Action"), KafkaOffset(1)),
- KafkaMessage(Book("Effective Akka"), KafkaOffset(2)),
+ KafkaMessage(Book("Pekko Concurrency"), KafkaOffset(0)),
+ KafkaMessage(Book("Pekko in Action"), KafkaOffset(1)),
+ KafkaMessage(Book("Effective Pekko"), KafkaOffset(2)),
KafkaMessage(Book("Learning Scala"), KafkaOffset(3)),
KafkaMessage(Book("Scala Puzzlers"), KafkaOffset(4)),
KafkaMessage(Book("Scala for Spark in Production"), KafkaOffset(5)))
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 9e68182ea..827161eaa 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
@@ -101,9 +101,9 @@ object ScalaTestUtils extends TestUtils with Matchers {
type Assertion = org.scalatest.Assertion
val books: Sequence[ByteString] = List(
- "Akka Concurrency",
- "Akka in Action",
- "Effective Akka",
+ "Pekko Concurrency",
+ "Pekko in Action",
+ "Effective Pekko",
"Learning Scala",
"Programming in Scala Programming").map(ByteString(_))
diff --git a/ironmq/src/test/resources/application.conf b/ironmq/src/test/resources/application.conf
index d4be6796c..97cbf94dd 100644
--- a/ironmq/src/test/resources/application.conf
+++ b/ironmq/src/test/resources/application.conf
@@ -5,7 +5,7 @@ pekko.connectors.ironmq {
endpoint = "http://localhost:8080"
credentials {
token = "adminToken"
- project-id = "alpakka"
+ project-id = "connectors"
}
}
pekko {
diff --git a/jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsConsumerSettings.scala b/jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsConsumerSettings.scala
index 8dcd8ff82..6a2d91092 100644
--- a/jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsConsumerSettings.scala
+++ b/jms/src/main/scala/org/apache/pekko/stream/connectors/jms/JmsConsumerSettings.scala
@@ -98,7 +98,7 @@ final class JmsConsumerSettings private (
def withMaxPendingAcks(value: Int): JmsConsumerSettings = copy(maxPendingAcks = value)
/**
- * For use with transactions, if true the stream fails if Alpakka rolls back the transaction when `ackTimeout` is hit.
+ * For use with transactions, if true the stream fails if Pekko Connectors rolls back the transaction when `ackTimeout` is hit.
*/
def withFailStreamOnAckTimeout(value: Boolean): JmsConsumerSettings =
if (failStreamOnAckTimeout == value) this else copy(failStreamOnAckTimeout = value)
diff --git a/kudu/src/main/scala/org/apache/pekko/stream/connectors/kudu/KuduAttributes.scala b/kudu/src/main/scala/org/apache/pekko/stream/connectors/kudu/KuduAttributes.scala
index 7d1d7fe78..6c3bd2884 100644
--- a/kudu/src/main/scala/org/apache/pekko/stream/connectors/kudu/KuduAttributes.scala
+++ b/kudu/src/main/scala/org/apache/pekko/stream/connectors/kudu/KuduAttributes.scala
@@ -20,7 +20,7 @@ import pekko.stream.Attributes.Attribute
import org.apache.kudu.client.KuduClient
/**
- * Akka Stream attributes that are used when materializing Kudu stream blueprints.
+ * Pekko Stream attributes that are used when materializing Kudu stream blueprints.
*/
object KuduAttributes {
diff --git a/kudu/src/test/java/docs/javadsl/KuduTableTest.java b/kudu/src/test/java/docs/javadsl/KuduTableTest.java
index 9984de6b2..f90e9b3f3 100644
--- a/kudu/src/test/java/docs/javadsl/KuduTableTest.java
+++ b/kudu/src/test/java/docs/javadsl/KuduTableTest.java
@@ -79,7 +79,7 @@ public class KuduTableTest {
CreateTableOptions createTableOptions =
new CreateTableOptions().setNumReplicas(1).setRangePartitionColumns(rangeKeys);
- // Alpakka settings
+ // Pekko Connectors Settings
KuduTableSettings<Person> tableSettings =
KuduTableSettings.create("tablenameSink", schema, createTableOptions, kuduConverter);
// #configure
diff --git a/kudu/src/test/scala/docs/scaladsl/KuduTableSpec.scala b/kudu/src/test/scala/docs/scaladsl/KuduTableSpec.scala
index 43a8ee462..82156526e 100644
--- a/kudu/src/test/scala/docs/scaladsl/KuduTableSpec.scala
+++ b/kudu/src/test/scala/docs/scaladsl/KuduTableSpec.scala
@@ -64,7 +64,7 @@ class KuduTableSpec
val rangeKeys = List("key")
val createTableOptions = new CreateTableOptions().setNumReplicas(1).setRangePartitionColumns(rangeKeys.asJava)
- // Alpakka settings
+ // Pekko Connectors Settings
val kuduTableSettings = KuduTableSettings("test", schema, createTableOptions, kuduConverter)
// #configure
diff --git a/project/Dependencies.scala b/project/Dependencies.scala
index efe5f2fa7..2d087cd58 100644
--- a/project/Dependencies.scala
+++ b/project/Dependencies.scala
@@ -210,7 +210,7 @@ object Dependencies {
"io.specto" % "hoverfly-java" % hoverflyVersion % Test // ApacheV2
) ++ Mockito)
val GoogleBigQueryStorage = Seq(
- // see Akka gRPC version in plugins.sbt
+ // see Pekko gRPC version in plugins.sbt
libraryDependencies ++= Seq(
// https://github.com/googleapis/java-bigquerystorage/tree/master/proto-google-cloud-bigquerystorage-v1
"com.google.api.grpc" % "proto-google-cloud-bigquerystorage-v1" % "1.22.0" % "protobuf-src", // ApacheV2
@@ -232,7 +232,7 @@ object Dependencies {
) ++ Mockito)
val GooglePubSubGrpc = Seq(
- // see Akka gRPC version in plugins.sbt
+ // see Pekko gRPC version in plugins.sbt
libraryDependencies ++= Seq(
// https://github.com/googleapis/java-pubsub/tree/master/proto-google-cloud-pubsub-v1/
"com.google.cloud" % "google-cloud-pubsub" % "1.112.5" % "protobuf-src", // ApacheV2
diff --git a/project/TestChanged.scala b/project/TestChanged.scala
index f41e4e07d..b93c5400a 100644
--- a/project/TestChanged.scala
+++ b/project/TestChanged.scala
@@ -53,7 +53,7 @@ object TestChanged extends AutoPlugin {
}
private def shouldBuild(projectName: String, changedDirectories: Set[String]) = projectName match {
- case "alpakka" => false
+ case "connectors" => false
case re"pekko-connectors-(.+)$subproject" =>
changedDirectories.contains(subproject) || changedDirectories.contains("") || changedDirectories.contains(
"project")
diff --git a/reference/src/main/scala/org/apache/pekko/stream/connectors/reference/Resource.scala b/reference/src/main/scala/org/apache/pekko/stream/connectors/reference/Resource.scala
index 93d148b20..1bb7f7a9d 100644
--- a/reference/src/main/scala/org/apache/pekko/stream/connectors/reference/Resource.scala
+++ b/reference/src/main/scala/org/apache/pekko/stream/connectors/reference/Resource.scala
@@ -32,15 +32,15 @@ import com.typesafe.config.Config
*
* For example dynamodb connector needs a DynamoClient to create Sources and Flows.
* Another example is Google Pub Sub gRPC connector that uses Grpc Publishers and
- * Subscribers to create Sources and Sinks. Another connector, Alpakka Kafka, uses
+ * Subscribers to create Sources and Sinks. Another connector, Pekko Connectors Kafka, uses
* an actor that can be shared across different streams.
*
* If your connector uses such a resource and it is possible to reuse that resource
- * across different Akka Stream operator factories, put that resource to a separate
+ * across different Pekko Stream operator factories, put that resource to a separate
* class like below.
*/
final class Resource private (val settings: ResourceSettings) {
- // a resource that is to be used when creating Akka Stream operators.
+ // a resource that is to be used when creating Pekko Stream operators.
val connection = Flow[ByteString].map(_.reverse)
/**
diff --git a/s3/src/main/scala/org/apache/pekko/stream/connectors/s3/S3Attributes.scala b/s3/src/main/scala/org/apache/pekko/stream/connectors/s3/S3Attributes.scala
index 28b9b138b..5d35e6569 100644
--- a/s3/src/main/scala/org/apache/pekko/stream/connectors/s3/S3Attributes.scala
+++ b/s3/src/main/scala/org/apache/pekko/stream/connectors/s3/S3Attributes.scala
@@ -18,7 +18,7 @@ import pekko.stream.Attributes
import pekko.stream.Attributes.Attribute
/**
- * Akka Stream attributes that are used when materializing S3 stream blueprints.
+ * Pekko Stream attributes that are used when materializing S3 stream blueprints.
*/
object S3Attributes {
diff --git a/s3/src/test/java/docs/javadsl/S3Test.java b/s3/src/test/java/docs/javadsl/S3Test.java
index ce8778caa..1b8ef3469 100644
--- a/s3/src/test/java/docs/javadsl/S3Test.java
+++ b/s3/src/test/java/docs/javadsl/S3Test.java
@@ -137,7 +137,7 @@ public class S3Test extends S3WireMockBase {
// #download
- // #downloadToAkkaHttp
+ // #downloadToPekkoHttp
metadataCompletionStage.thenApply(
metadata ->
HttpResponse.create()
@@ -149,7 +149,7 @@ public class S3Test extends S3WireMockBase {
.orElse(ContentTypes.APPLICATION_OCTET_STREAM),
metadata.getContentLength(),
s3Source)));
- // #downloadToAkkaHttp
+ // #downloadToPekkoHttp
String result = dataCompletionStage.toCompletableFuture().get(5, TimeUnit.SECONDS);
ObjectMetadata metadata =
diff --git a/s3/src/test/scala/docs/scaladsl/S3SourceSpec.scala b/s3/src/test/scala/docs/scaladsl/S3SourceSpec.scala
index 965ef13d3..12e2db6ac 100644
--- a/s3/src/test/scala/docs/scaladsl/S3SourceSpec.scala
+++ b/s3/src/test/scala/docs/scaladsl/S3SourceSpec.scala
@@ -53,7 +53,7 @@ class S3SourceSpec extends S3WireMockBase with S3ClientIntegrationSpec {
data.utf8String shouldBe body
- // #downloadToAkkaHttp
+ // #downloadToPekkoHttp
HttpResponse(
entity = HttpEntity(
metadata.contentType
@@ -61,7 +61,7 @@ class S3SourceSpec extends S3WireMockBase with S3ClientIntegrationSpec {
.getOrElse(ContentTypes.`application/octet-stream`),
metadata.contentLength,
s3Source))
- // #downloadToAkkaHttp
+ // #downloadToPekkoHttp
}
"S3Source" should "use custom settings when downloading a file" in {
diff --git a/solr/src/test/java/docs/javadsl/SolrTest.java b/solr/src/test/java/docs/javadsl/SolrTest.java
index 96521d8c5..7a80171cc 100644
--- a/solr/src/test/java/docs/javadsl/SolrTest.java
+++ b/solr/src/test/java/docs/javadsl/SolrTest.java
@@ -348,7 +348,7 @@ public class SolrTest {
Source<CommittableMessage, NotUsed> kafkaConsumerSource = Source.from(messagesFromKafka);
// #kafka-example
- // Note: This code mimics Alpakka Kafka APIs
+ // Note: This code mimics Pekko Connectors Kafka APIs
CompletionStage<Done> completion =
kafkaConsumerSource // Assume we get this from Kafka
.map(
@@ -720,7 +720,7 @@ public class SolrTest {
Source<CommittableOffset, NotUsed> kafkaConsumerSource = Source.from(messagesFromKafka);
// #kafka-example-PT
- // Note: This code mimics Alpakka Kafka APIs
+ // Note: This code mimics Pekko Connectors Kafka APIs
CompletionStage<Done> completion =
kafkaConsumerSource // Assume we get this from Kafka
.map(
diff --git a/solr/src/test/scala/docs/scaladsl/SolrSpec.scala b/solr/src/test/scala/docs/scaladsl/SolrSpec.scala
index 0508bc977..9f2f5e3ef 100644
--- a/solr/src/test/scala/docs/scaladsl/SolrSpec.scala
+++ b/solr/src/test/scala/docs/scaladsl/SolrSpec.scala
@@ -81,7 +81,7 @@ class SolrSpec extends AnyWordSpec with Matchers with BeforeAndAfterAll with Sca
}
// #define-class
- "Alpakka Solr" should {
+ "Pekko Connectors Solr" should {
"consume and publish SolrInputDocument" in {
// Copy collection1 to collectionName through document stream
val collectionName = createCollection()
@@ -292,7 +292,7 @@ class SolrSpec extends AnyWordSpec with Matchers with BeforeAndAfterAll with Sca
CommittableMessage(Book("Book 3"), CommittableOffset(2)))
val kafkaConsumerSource = Source(messagesFromKafka)
// #kafka-example
- // Note: This code mimics Alpakka Kafka APIs
+ // Note: This code mimics Pekko Connectors Kafka APIs
val copyCollection = kafkaConsumerSource
.map { kafkaMessage: CommittableMessage =>
val book = kafkaMessage.book
@@ -655,7 +655,7 @@ class SolrSpec extends AnyWordSpec with Matchers with BeforeAndAfterAll with Sca
CommittableOffset(2))
val kafkaConsumerSource = Source(messagesFromKafka)
// #kafka-example-PT
- // Note: This code mimics Alpakka Kafka APIs
+ // Note: This code mimics Pekko Connectors Kafka APIs
val copyCollection = kafkaConsumerSource
.map { offset: CommittableOffset =>
// Transform message so that we can write to solr
diff --git a/sqs/src/test/java/docs/javadsl/SqsPublishTest.java b/sqs/src/test/java/docs/javadsl/SqsPublishTest.java
index cf0f66bf2..21a80e56c 100644
--- a/sqs/src/test/java/docs/javadsl/SqsPublishTest.java
+++ b/sqs/src/test/java/docs/javadsl/SqsPublishTest.java
@@ -75,7 +75,7 @@ public class SqsPublishTest extends BaseSqsTest {
CompletionStage<Done> done =
// #run-string
- Source.single("alpakka")
+ Source.single("connectors")
.runWith(
SqsPublishSink.create(queueUrl, SqsPublishSettings.create(), sqsClient), system);
// #run-string
@@ -87,7 +87,7 @@ public class SqsPublishTest extends BaseSqsTest {
.get(2, TimeUnit.SECONDS)
.messages();
assertEquals(1, messages.size());
- assertEquals("alpakka", messages.get(0).body());
+ assertEquals("connectors", messages.get(0).body());
}
@Test
@@ -98,7 +98,7 @@ public class SqsPublishTest extends BaseSqsTest {
CompletionStage<Done> done =
// #run-send-request
// for fix SQS queue
- Source.single(SendMessageRequest.builder().messageBody("alpakka").build())
+ Source.single(SendMessageRequest.builder().messageBody("connectors").build())
.runWith(
SqsPublishSink.messageSink(queueUrl, SqsPublishSettings.create(), sqsClient),
system);
@@ -112,7 +112,7 @@ public class SqsPublishTest extends BaseSqsTest {
.get(2, TimeUnit.SECONDS)
.messages();
assertEquals(1, messages.size());
- assertEquals("alpakka", messages.get(0).body());
+ assertEquals("connectors", messages.get(0).body());
}
@Test
@@ -124,7 +124,7 @@ public class SqsPublishTest extends BaseSqsTest {
// #run-send-request
// for dynamic SQS queues
Source.single(
- SendMessageRequest.builder().messageBody("alpakka").queueUrl(queueUrl).build())
+ SendMessageRequest.builder().messageBody("connectors").queueUrl(queueUrl).build())
.runWith(SqsPublishSink.messageSink(SqsPublishSettings.create(), sqsClient), system);
// #run-send-request
done.toCompletableFuture().get(10, TimeUnit.SECONDS);
@@ -135,7 +135,7 @@ public class SqsPublishTest extends BaseSqsTest {
.get(2, TimeUnit.SECONDS)
.messages();
assertEquals(1, messages.size());
- assertEquals("alpakka", messages.get(0).body());
+ assertEquals("connectors", messages.get(0).body());
}
@Test
diff --git a/sqs/src/test/java/docs/javadsl/SqsSourceTest.java b/sqs/src/test/java/docs/javadsl/SqsSourceTest.java
index 686c9cd18..81f7c6e97 100644
--- a/sqs/src/test/java/docs/javadsl/SqsSourceTest.java
+++ b/sqs/src/test/java/docs/javadsl/SqsSourceTest.java
@@ -122,7 +122,7 @@ public class SqsSourceTest extends BaseSqsTest {
// #init-custom-client
customSqsClient
- .sendMessage(SendMessageRequest.builder().queueUrl(queueUrl).messageBody("alpakka").build())
+ .sendMessage(SendMessageRequest.builder().queueUrl(queueUrl).messageBody("connectors").build())
.get(2, TimeUnit.SECONDS);
final CompletionStage<String> cs =
@@ -131,6 +131,6 @@ public class SqsSourceTest extends BaseSqsTest {
.map(Message::body)
.runWith(Sink.head(), system);
- assertEquals("alpakka", cs.toCompletableFuture().get(20, TimeUnit.SECONDS));
+ assertEquals("connectors", cs.toCompletableFuture().get(20, TimeUnit.SECONDS));
}
}
diff --git a/sqs/src/test/scala/docs/scaladsl/SqsPublishSpec.scala b/sqs/src/test/scala/docs/scaladsl/SqsPublishSpec.scala
index 39a45d143..8af058cbb 100644
--- a/sqs/src/test/scala/docs/scaladsl/SqsPublishSpec.scala
+++ b/sqs/src/test/scala/docs/scaladsl/SqsPublishSpec.scala
@@ -102,12 +102,12 @@ class SqsPublishSpec extends AnyFlatSpec with Matchers with DefaultTestContext w
val future =
// #run-string
Source
- .single("alpakka")
+ .single("connectors")
.runWith(SqsPublishSink(queueUrl))
// #run-string
future.futureValue shouldBe Done
- receiveMessage().body() shouldBe "alpakka"
+ receiveMessage().body() shouldBe "connectors"
}
}
@@ -117,14 +117,14 @@ class SqsPublishSpec extends AnyFlatSpec with Matchers with DefaultTestContext w
// #run-send-request
// for fix SQS queue
Source
- .single(SendMessageRequest.builder().messageBody("alpakka").build())
+ .single(SendMessageRequest.builder().messageBody("connectors").build())
.runWith(SqsPublishSink.messageSink(queueUrl))
// #run-send-request
future.futureValue shouldBe Done
- receiveMessage().body() shouldBe "alpakka"
+ receiveMessage().body() shouldBe "connectors"
}
}
@@ -134,13 +134,13 @@ class SqsPublishSpec extends AnyFlatSpec with Matchers with DefaultTestContext w
// #run-send-request
// for dynamic SQS queues
Source
- .single(SendMessageRequest.builder().messageBody("alpakka").queueUrl(queueUrl).build())
+ .single(SendMessageRequest.builder().messageBody("connectors").queueUrl(queueUrl).build())
.runWith(SqsPublishSink.messageSink())
// #run-send-request
future.futureValue shouldBe Done
- receiveMessage().body() shouldBe "alpakka"
+ receiveMessage().body() shouldBe "connectors"
}
}
@@ -197,7 +197,7 @@ class SqsPublishSpec extends AnyFlatSpec with Matchers with DefaultTestContext w
// #flow
// for fix SQS queue
Source
- .single(SendMessageRequest.builder().messageBody("alpakka").build())
+ .single(SendMessageRequest.builder().messageBody("connectors").build())
.via(SqsPublishFlow(queueUrl))
.runWith(Sink.head)
@@ -205,9 +205,9 @@ class SqsPublishSpec extends AnyFlatSpec with Matchers with DefaultTestContext w
val result = future.futureValue
result.result
- result.result.md5OfMessageBody() shouldBe md5HashString("alpakka")
+ result.result.md5OfMessageBody() shouldBe md5HashString("connectors")
- receiveMessage().body() shouldBe "alpakka"
+ receiveMessage().body() shouldBe "connectors"
}
}
@@ -217,15 +217,15 @@ class SqsPublishSpec extends AnyFlatSpec with Matchers with DefaultTestContext w
// #flow
// for dynamic SQS queues
Source
- .single(SendMessageRequest.builder().messageBody("alpakka").queueUrl(queueUrl).build())
+ .single(SendMessageRequest.builder().messageBody("connectors").queueUrl(queueUrl).build())
.via(SqsPublishFlow())
.runWith(Sink.head)
// #flow
val result = future.futureValue
- result.result.md5OfMessageBody() shouldBe md5HashString("alpakka")
+ result.result.md5OfMessageBody() shouldBe md5HashString("connectors")
- receiveMessage().body() shouldBe "alpakka"
+ receiveMessage().body() shouldBe "connectors"
}
}
@@ -241,7 +241,7 @@ class SqsPublishSpec extends AnyFlatSpec with Matchers with DefaultTestContext w
.single(
SendMessageRequest
.builder()
- .messageBody("alpakka")
+ .messageBody("connectors")
.messageGroupId("group-id")
.messageDeduplicationId("deduplication-id")
.build())
@@ -249,10 +249,10 @@ class SqsPublishSpec extends AnyFlatSpec with Matchers with DefaultTestContext w
.runWith(Sink.head)
val result = future.futureValue
- result.result.md5OfMessageBody() shouldBe md5HashString("alpakka")
+ result.result.md5OfMessageBody() shouldBe md5HashString("connectors")
result.result.sequenceNumber() should not be empty
- receiveMessage().body() shouldBe "alpakka"
+ receiveMessage().body() shouldBe "connectors"
}
ignore should "put message in a flow, batch, then pass the result further with fifo queues" taggedAs Integration in new IntegrationFixture(
diff --git a/sqs/src/test/scala/docs/scaladsl/SqsSourceSpec.scala b/sqs/src/test/scala/docs/scaladsl/SqsSourceSpec.scala
index 950000abb..edc18d85a 100644
--- a/sqs/src/test/scala/docs/scaladsl/SqsSourceSpec.scala
+++ b/sqs/src/test/scala/docs/scaladsl/SqsSourceSpec.scala
@@ -60,7 +60,7 @@ class SqsSourceSpec extends AnyFlatSpec with ScalaFutures with Matchers with Def
SendMessageRequest
.builder()
.queueUrl(queueUrl)
- .messageBody("alpakka")
+ .messageBody("connectors")
.build()
sqsClient.sendMessage(sendMessageRequest).get(2, TimeUnit.SECONDS)
@@ -68,7 +68,7 @@ class SqsSourceSpec extends AnyFlatSpec with ScalaFutures with Matchers with Def
val future = SqsSource(queueUrl, sqsSourceSettings)
.runWith(Sink.head)
- future.futureValue.body() shouldBe "alpakka"
+ future.futureValue.body() shouldBe "connectors"
}
it should "continue streaming if receives an empty response" taggedAs Integration in {
@@ -112,7 +112,7 @@ class SqsSourceSpec extends AnyFlatSpec with ScalaFutures with Matchers with Def
SendMessageRequest
.builder()
.queueUrl(queueUrl)
- .messageBody("alpakka")
+ .messageBody("connectors")
.build()
sqsClient.sendMessage(sendMessageRequest).get(2, TimeUnit.SECONDS)
@@ -134,7 +134,7 @@ class SqsSourceSpec extends AnyFlatSpec with ScalaFutures with Matchers with Def
SendMessageRequest
.builder()
.queueUrl(queueUrl)
- .messageBody("alpakka")
+ .messageBody("connectors")
.build()
sqsClient.sendMessage(sendMessageRequest).get(2, TimeUnit.SECONDS)
@@ -156,7 +156,7 @@ class SqsSourceSpec extends AnyFlatSpec with ScalaFutures with Matchers with Def
SendMessageRequest
.builder()
.queueUrl(queueUrl)
- .messageBody("alpakka")
+ .messageBody("connectors")
.build()
sqsClient.sendMessage(sendMessageRequest).get(2, TimeUnit.SECONDS)
@@ -182,7 +182,7 @@ class SqsSourceSpec extends AnyFlatSpec with ScalaFutures with Matchers with Def
SendMessageRequest
.builder()
.queueUrl(queueUrl)
- .messageBody("alpakka")
+ .messageBody("connectors")
.messageAttributes(messageAttributes.asJava)
.build()
@@ -272,7 +272,7 @@ class SqsSourceSpec extends AnyFlatSpec with ScalaFutures with Matchers with Def
SendMessageRequest
.builder()
.queueUrl(queueUrl)
- .messageBody("alpakka")
+ .messageBody("connectors")
.build()
customSqsClient.sendMessage(sendMessageRequest).get(2, TimeUnit.SECONDS)
@@ -280,7 +280,7 @@ class SqsSourceSpec extends AnyFlatSpec with ScalaFutures with Matchers with Def
val future = SqsSource(queueUrl, sqsSourceSettings)(customSqsClient)
.runWith(Sink.head)
- future.futureValue.body() shouldBe "alpakka"
+ future.futureValue.body() shouldBe "connectors"
}
}
@@ -313,7 +313,7 @@ class SqsSourceSpec extends AnyFlatSpec with ScalaFutures with Matchers with Def
SendMessageRequest
.builder()
.queueUrl(queueUrl)
- .messageBody("alpakka")
+ .messageBody("connectors")
.build()
sqsClient.sendMessage(sendMessageRequest).get(2, TimeUnit.SECONDS)
@@ -332,7 +332,7 @@ class SqsSourceSpec extends AnyFlatSpec with ScalaFutures with Matchers with Def
SendMessageRequest
.builder()
.queueUrl(queueUrl)
- .messageBody("alpakka")
+ .messageBody("connectors")
.build()
sqsClient.sendMessage(sendMessageRequest).get(2, TimeUnit.SECONDS)
diff --git a/sqs/src/test/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishSinkSpec.scala b/sqs/src/test/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishSinkSpec.scala
index 58df0da71..0750de72d 100644
--- a/sqs/src/test/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishSinkSpec.scala
+++ b/sqs/src/test/scala/org/apache/pekko/stream/connectors/sqs/scaladsl/SqsPublishSinkSpec.scala
@@ -77,7 +77,7 @@ class SqsPublishSinkSpec extends AnyFlatSpec with Matchers with DefaultTestConte
val request = SendMessageRequest
.builder()
.queueUrl(queue1)
- .messageBody("alpakka")
+ .messageBody("connectors")
.build()
sqsClient.sendMessage(request)
@@ -92,7 +92,7 @@ class SqsPublishSinkSpec extends AnyFlatSpec with Matchers with DefaultTestConte
val result =
sqsClient.receiveMessage(ReceiveMessageRequest.builder().queueUrl(queue2).build()).get(2, TimeUnit.SECONDS)
result.messages().size() shouldBe 1
- result.messages().get(0).body() shouldBe "alpakka"
+ result.messages().get(0).body() shouldBe "connectors"
}
it should "failure the promise on upstream failure" in {
diff --git a/unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/scaladsl/UnixDomainSocket.scala b/unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/scaladsl/UnixDomainSocket.scala
index 321d71410..8527736c4 100644
--- a/unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/scaladsl/UnixDomainSocket.scala
+++ b/unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/scaladsl/UnixDomainSocket.scala
@@ -77,7 +77,7 @@ object UnixDomainSocket extends ExtensionId[UnixDomainSocket] with ExtensionIdPr
}
/**
- * Provides Unix Domain Socket functionality to Akka Streams with an interface similar to Akka's Tcp class.
+ * Provides Unix Domain Socket functionality to Pekko Streams with an interface similar to Akka's Tcp class.
*/
final class UnixDomainSocket(system: ExtendedActorSystem) extends UnixDomainSocketImpl(system) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org