Skip to content

Commit

Permalink
Rename akka reference to pekko (apache#467)
Browse files Browse the repository at this point in the history
  • Loading branch information
mdedetrich authored Feb 9, 2024
1 parent 71141e1 commit 43ee6b7
Show file tree
Hide file tree
Showing 7 changed files with 10 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -167,7 +167,7 @@ public void sessionFromBucket() {

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(
() -> {
Expand Down
2 changes: 1 addition & 1 deletion couchbase/src/test/java/docs/javadsl/DiscoveryTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -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() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand Down
2 changes: 1 addition & 1 deletion couchbase/src/test/scala/docs/scaladsl/DiscoverySpec.scala
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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 = _

Expand Down
6 changes: 3 additions & 3 deletions docker-compose.yml
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down

0 comments on commit 43ee6b7

Please sign in to comment.