This is an automated email from the ASF dual-hosted git repository.
mdedetrich pushed a commit to branch 1.0.x
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors.git
The following commit(s) were added to refs/heads/1.0.x by this push:
new 75bcc63a5 Rename akka reference to pekko (#467)
75bcc63a5 is described below
commit 75bcc63a585ba0704480a9361dbd2016a3bc02bf
Author: Matthew de Detrich <[email protected]>
AuthorDate: Fri Feb 9 15:28:52 2024 +0100
Rename akka reference to pekko (#467)
(cherry picked from commit 43ee6b702cc1ecbbf23a78d0acd3de957b21add4)
---
couchbase/src/test/java/docs/javadsl/CouchbaseExamplesTest.java | 2 +-
couchbase/src/test/java/docs/javadsl/DiscoveryTest.java | 2 +-
.../src/test/scala/docs/scaladsl/CouchbaseSessionExamplesSpec.scala | 2 +-
couchbase/src/test/scala/docs/scaladsl/CouchbaseSourceSpec.scala | 2 +-
couchbase/src/test/scala/docs/scaladsl/DiscoverySpec.scala | 2 +-
.../stream/connectors/couchbase/testing/CouchbaseSupport.scala | 4 ++--
docker-compose.yml | 6 +++---
7 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/couchbase/src/test/java/docs/javadsl/CouchbaseExamplesTest.java
b/couchbase/src/test/java/docs/javadsl/CouchbaseExamplesTest.java
index 6ed6e10f8..aae79297d 100644
--- a/couchbase/src/test/java/docs/javadsl/CouchbaseExamplesTest.java
+++ b/couchbase/src/test/java/docs/javadsl/CouchbaseExamplesTest.java
@@ -167,7 +167,7 @@ public class CouchbaseExamplesTest {
CouchbaseCluster cluster = CouchbaseCluster.create("localhost");
cluster.authenticate(new PasswordAuthenticator("Administrator",
"password"));
- Bucket bucket = cluster.openBucket("akka");
+ Bucket bucket = cluster.openBucket("pekko");
CouchbaseSession session = CouchbaseSession.create(bucket);
actorSystem.registerOnTermination(
() -> {
diff --git a/couchbase/src/test/java/docs/javadsl/DiscoveryTest.java
b/couchbase/src/test/java/docs/javadsl/DiscoveryTest.java
index a20a18676..06d1c0c5f 100644
--- a/couchbase/src/test/java/docs/javadsl/DiscoveryTest.java
+++ b/couchbase/src/test/java/docs/javadsl/DiscoveryTest.java
@@ -41,7 +41,7 @@ public class DiscoveryTest {
@Rule public final LogCapturingJunit4 logCapturing = new
LogCapturingJunit4();
private static ActorSystem actorSystem;
- private static final String bucketName = "akka";
+ private static final String bucketName = "pekko";
@BeforeClass
public static void beforeAll() {
diff --git
a/couchbase/src/test/scala/docs/scaladsl/CouchbaseSessionExamplesSpec.scala
b/couchbase/src/test/scala/docs/scaladsl/CouchbaseSessionExamplesSpec.scala
index bdd479ecb..b0affffea 100644
--- a/couchbase/src/test/scala/docs/scaladsl/CouchbaseSessionExamplesSpec.scala
+++ b/couchbase/src/test/scala/docs/scaladsl/CouchbaseSessionExamplesSpec.scala
@@ -91,7 +91,7 @@ class CouchbaseSessionExamplesSpec
val cluster: CouchbaseCluster = CouchbaseCluster.create("localhost")
cluster.authenticate(new PasswordAuthenticator("Administrator",
"password"))
- val bucket: Bucket = cluster.openBucket("akka")
+ val bucket: Bucket = cluster.openBucket("pekko")
val session: CouchbaseSession = CouchbaseSession(bucket)
actorSystem.registerOnTermination {
session.close()
diff --git a/couchbase/src/test/scala/docs/scaladsl/CouchbaseSourceSpec.scala
b/couchbase/src/test/scala/docs/scaladsl/CouchbaseSourceSpec.scala
index 9b056079d..f8494a858 100644
--- a/couchbase/src/test/scala/docs/scaladsl/CouchbaseSourceSpec.scala
+++ b/couchbase/src/test/scala/docs/scaladsl/CouchbaseSourceSpec.scala
@@ -64,7 +64,7 @@ class CouchbaseSourceSpec
val cluster: CouchbaseCluster = CouchbaseCluster.create("localhost")
cluster.authenticate(new PasswordAuthenticator("Administrator",
"password"))
- val bucket: Bucket = cluster.openBucket("akka")
+ val bucket: Bucket = cluster.openBucket("pekko")
val session: CouchbaseSession = CouchbaseSession(bucket)
actorSystem.registerOnTermination {
cluster.disconnect()
diff --git a/couchbase/src/test/scala/docs/scaladsl/DiscoverySpec.scala
b/couchbase/src/test/scala/docs/scaladsl/DiscoverySpec.scala
index 5e5c0a9bc..8914f0160 100644
--- a/couchbase/src/test/scala/docs/scaladsl/DiscoverySpec.scala
+++ b/couchbase/src/test/scala/docs/scaladsl/DiscoverySpec.scala
@@ -36,7 +36,7 @@ class DiscoverySpec extends AnyWordSpec with Matchers with
BeforeAndAfterAll wit
override implicit def patienceConfig: PatienceConfig =
PatienceConfig(10.seconds, 250.millis)
- val bucketName = "akka"
+ val bucketName = "pekko"
override def afterAll(): Unit =
actorSystem.terminate()
diff --git
a/couchbase/src/test/scala/org/apache/pekko/stream/connectors/couchbase/testing/CouchbaseSupport.scala
b/couchbase/src/test/scala/org/apache/pekko/stream/connectors/couchbase/testing/CouchbaseSupport.scala
index 808413f72..d0eb150ba 100644
---
a/couchbase/src/test/scala/org/apache/pekko/stream/connectors/couchbase/testing/CouchbaseSupport.scala
+++
b/couchbase/src/test/scala/org/apache/pekko/stream/connectors/couchbase/testing/CouchbaseSupport.scala
@@ -60,8 +60,8 @@ trait CouchbaseSupport {
val sessionSettings = CouchbaseSessionSettings(actorSystem)
val writeSettings: CouchbaseWriteSettings =
CouchbaseWriteSettings().withReplicateTo(ReplicateTo.NONE)
- val bucketName = "akka"
- val queryBucketName = "akkaquery"
+ val bucketName = "pekko"
+ val queryBucketName = "pekkoquery"
var session: CouchbaseSession = _
diff --git a/docker-compose.yml b/docker-compose.yml
index ce8e07414..573a97b92 100644
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -49,20 +49,20 @@ services:
--services data,index,query,fts
couchbase-cli bucket-create -c couchbase \
-u Administrator -p password \
- --bucket akka \
+ --bucket pekko \
--bucket-type couchbase \
--bucket-ramsize 100 \
--bucket-replica 1 \
--wait
couchbase-cli bucket-create -c couchbase \
-u Administrator -p password \
- --bucket akkaquery \
+ --bucket pekkoquery \
--bucket-type couchbase \
--bucket-ramsize 100 \
--bucket-replica 1 \
--wait
sleep 2 # just wait a tiny bit more after creating the bucket
- echo 'CREATE PRIMARY INDEX ON akkaquery USING GSI;' | \
+ echo 'CREATE PRIMARY INDEX ON pekkoquery USING GSI;' | \
cbq -c Administrator:password -e http://couchbase:8093
"
elasticmq:
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
