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-platform-guide.git
The following commit(s) were added to refs/heads/main by this push:
new 10bbed26 Migrate shopping-cart-service-cassandra-java (#66)
10bbed26 is described below
commit 10bbed267663c867aaf0e93f75ba5b721615b022
Author: Laglangyue <[email protected]>
AuthorDate: Mon Dec 25 03:27:31 2023 +0800
Migrate shopping-cart-service-cassandra-java (#66)
* wip: migrate to pekko
* use `mvn spotless:apply` to reformat
* replace conf
* replace conf
* add pekko-discovery-kubernetes-api
* fix style and imports
* undo comment change
* Update README.md
* fix class names
* Update pom.xml
* Update pom.xml
* Update persistence.conf
* Update persistence.conf
---------
Co-authored-by: Jiafu Tang <[email protected]>
Co-authored-by: PJ Fanning <[email protected]>
---
.../shopping-cart-service-cassandra-java/README.md | 4 +-
.../shopping-cart-service-cassandra-java/pom.xml | 129 ++++++++++++---------
.../main/java/shopping/cart/CborSerializable.java | 2 +-
.../shopping/cart/ItemPopularityProjection.java | 24 ++--
.../cart/ItemPopularityProjectionHandler.java | 6 +-
.../shopping/cart/ItemPopularityRepository.java | 2 +-
.../cart/ItemPopularityRepositoryImpl.java | 4 +-
.../src/main/java/shopping/cart/Main.java | 20 ++--
.../shopping/cart/PublishEventsProjection.java | 30 ++---
.../cart/PublishEventsProjectionHandler.java | 10 +-
.../java/shopping/cart/SendOrderProjection.java | 24 ++--
.../shopping/cart/SendOrderProjectionHandler.java | 14 +--
.../src/main/java/shopping/cart/ShoppingCart.java | 22 ++--
.../java/shopping/cart/ShoppingCartServer.java | 16 +--
.../shopping/cart/ShoppingCartServiceImpl.java | 8 +-
.../src/main/resources/application.conf | 2 +-
.../src/main/resources/cluster.conf | 6 +-
.../src/main/resources/grpc.conf | 2 +-
.../src/main/resources/kafka.conf | 6 +-
.../src/main/resources/local-shared.conf | 16 +--
.../src/main/resources/local1.conf | 4 +-
.../src/main/resources/local2.conf | 4 +-
.../src/main/resources/local3.conf | 4 +-
.../src/main/resources/logback.xml | 2 +-
.../src/main/resources/persistence.conf | 24 ++--
.../src/main/resources/serialization.conf | 2 +-
.../java/shopping/cart/CreateTableTestUtils.java | 12 +-
.../test/java/shopping/cart/IntegrationTest.java | 34 +++---
.../cart/ItemPopularityIntegrationTest.java | 32 ++---
.../cart/ItemPopularityProjectionTest.java | 26 ++---
.../test/java/shopping/cart/ShoppingCartTest.java | 10 +-
.../src/test/resources/integration-test.conf | 18 +--
.../item-popularity-integration-test.conf | 6 +-
.../src/test/resources/logback-test.xml | 2 +-
34 files changed, 271 insertions(+), 256 deletions(-)
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/README.md
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/README.md
index 43b2a8dd..26fcd93e 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/README.md
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/README.md
@@ -9,8 +9,8 @@
2. Create Cassandra keyspace and tables:
```shell
- # creates keyspace and all tables needed for Akka Persistence
- # as well as the offset store table for Akka Projection
+ # creates keyspace and all tables needed for Pekko Persistence
+ # as well as the offset store table for Pekko Projection
docker exec -i shopping-cart-service-cassandra-java_cassandra_1 cqlsh -t <
ddl-scripts/create_tables.cql
```
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/pom.xml
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/pom.xml
index 0b182552..537a4d1c 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/pom.xml
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/pom.xml
@@ -15,99 +15,113 @@
</license>
</licenses>
- <!-- tag::akka-persistence-cassandra[] -->
+ <!-- tag::pekko-persistence-cassandra[] -->
<properties>
- <!-- end::akka-persistence-cassandra[] -->
+ <!-- end::pekko-persistence-cassandra[] -->
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
- <akka-grpc-maven-plugin.version>2.1.3</akka-grpc-maven-plugin.version>
+ <pekko.version>1.0.2</pekko.version>
+ <pekko-connectors-kafka.version>1.0.0</pekko-connectors-kafka.version>
+ <pekko-grpc.version>1.0.1</pekko-grpc.version>
+ <pekko-management.version>1.0.0</pekko-management.version>
+
<pekko-persistence-cassandra.version>1.0.0</pekko-persistence-cassandra.version>
+ <pekko-projection.version>1.0.0</pekko-projection.version>
<scala.binary.version>2.13</scala.binary.version>
<!-- needs to be defined to allow for overriding through mvn exec:exec
-DAPP_CONFIG=local1.conf -->
<APP_CONFIG>application.conf</APP_CONFIG>
<!-- Version of the Docker image is derived from git commit.
It can be defined with -Dversion.number=0.1-SNAPSHOT if git is
not used -->
<version.number>${git.commit.time}-${git.commit.id.abbrev}</version.number>
- <!-- tag::akka-persistence-cassandra[] -->
+ <!-- tag::pekko-persistence-cassandra[] -->
</properties>
- <!-- end::akka-persistence-cassandra[] -->
+ <!-- end::pekko-persistence-cassandra[] -->
<dependencyManagement>
<dependencies>
<dependency>
- <groupId>com.lightbend.akka</groupId>
-
<artifactId>akka-platform-dependencies_${scala.binary.version}</artifactId>
- <version>0.3.0</version>
+ <groupId>org.apache.pekko</groupId>
+ <artifactId>pekko-bom_${scala.binary.version}</artifactId>
+ <version>${pekko.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
- <!-- tag::akka-persistence-cassandra[] -->
+ <!-- tag::pekko-persistence-cassandra[] -->
<dependencies>
- <!-- end::akka-persistence-cassandra[] -->
+ <!-- end::pekko-persistence-cassandra[] -->
<dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-cluster-typed_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-cluster-typed_${scala.binary.version}</artifactId>
</dependency>
<dependency>
- <groupId>com.typesafe.akka</groupId>
-
<artifactId>akka-cluster-sharding-typed_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-cluster-sharding-typed_${scala.binary.version}</artifactId>
</dependency>
<dependency>
- <groupId>com.typesafe.akka</groupId>
-
<artifactId>akka-persistence-typed_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-persistence-typed_${scala.binary.version}</artifactId>
</dependency>
<dependency>
- <groupId>com.typesafe.akka</groupId>
-
<artifactId>akka-persistence-query_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-persistence-query_${scala.binary.version}</artifactId>
</dependency>
<dependency>
- <groupId>com.typesafe.akka</groupId>
-
<artifactId>akka-serialization-jackson_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-serialization-jackson_${scala.binary.version}</artifactId>
</dependency>
<dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-cluster-tools_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-cluster-tools_${scala.binary.version}</artifactId>
</dependency>
<dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-discovery_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+ <artifactId>pekko-discovery_${scala.binary.version}</artifactId>
</dependency>
- <!-- tag::akka-persistence-cassandra[] -->
<dependency>
- <groupId>com.typesafe.akka</groupId>
-
<artifactId>akka-persistence-cassandra_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-discovery-kubernetes-api_${scala.binary.version}</artifactId>
+ <version>${pekko-management.version}</version>
</dependency>
- <!-- end::akka-persistence-cassandra[] -->
+
+ <!-- tag::pekko-persistence-cassandra[] -->
<dependency>
- <groupId>com.lightbend.akka</groupId>
-
<artifactId>akka-projection-eventsourced_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-persistence-cassandra_${scala.binary.version}</artifactId>
+ <version>${pekko-persistence-cassandra.version}</version>
</dependency>
- <!-- tag::akka-projection-cassandra[] -->
+ <!-- end::pekko-persistence-cassandra[] -->
<dependency>
- <groupId>com.lightbend.akka</groupId>
-
<artifactId>akka-projection-cassandra_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-projection-eventsourced_${scala.binary.version}</artifactId>
+ <version>${pekko-projection.version}</version>
</dependency>
- <!-- end::akka-projection-cassandra[] -->
+ <!-- tag::pekko-projection-cassandra[] -->
<dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-stream-kafka_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-projection-cassandra_${scala.binary.version}</artifactId>
+ <version>${pekko-projection.version}</version>
</dependency>
+ <!-- end::pekko-projection-cassandra[] -->
<dependency>
- <groupId>com.lightbend.akka.management</groupId>
-
<artifactId>akka-management-cluster-http_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-connectors-kafka_${scala.binary.version}</artifactId>
+ <version>${pekko-connectors-kafka.version}</version>
</dependency>
<dependency>
- <groupId>com.lightbend.akka.management</groupId>
-
<artifactId>akka-management-cluster-bootstrap_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-management-cluster-http_${scala.binary.version}</artifactId>
+ <version>${pekko-management.version}</version>
</dependency>
<dependency>
- <groupId>com.lightbend.akka.discovery</groupId>
-
<artifactId>akka-discovery-kubernetes-api_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-management-cluster-bootstrap_${scala.binary.version}</artifactId>
+ <version>${pekko-management.version}</version>
</dependency>
<dependency>
- <groupId>com.lightbend.akka.grpc</groupId>
- <artifactId>akka-grpc-runtime_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+ <artifactId>pekko-grpc-runtime_${scala.binary.version}</artifactId>
+ <version>${pekko-grpc.version}</version>
</dependency>
<dependency>
@@ -117,23 +131,24 @@
</dependency>
<dependency>
- <groupId>com.typesafe.akka</groupId>
-
<artifactId>akka-actor-testkit-typed_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-actor-testkit-typed_${scala.binary.version}</artifactId>
<scope>test</scope>
</dependency>
<dependency>
- <groupId>com.typesafe.akka</groupId>
-
<artifactId>akka-persistence-testkit_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-persistence-testkit_${scala.binary.version}</artifactId>
<scope>test</scope>
</dependency>
<dependency>
- <groupId>com.lightbend.akka</groupId>
-
<artifactId>akka-projection-testkit_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-projection-testkit_${scala.binary.version}</artifactId>
+ <version>${pekko-projection.version}</version>
<scope>test</scope>
</dependency>
<dependency>
- <groupId>com.typesafe.akka</groupId>
-
<artifactId>akka-stream-testkit_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-stream-testkit_${scala.binary.version}</artifactId>
<scope>test</scope>
</dependency>
@@ -150,9 +165,9 @@
<scope>test</scope>
</dependency>
- <!-- tag::akka-persistence-cassandra[] -->
+ <!-- tag::pekko-persistence-cassandra[] -->
</dependencies>
- <!-- end::akka-persistence-cassandra[] -->
+ <!-- end::pekko-persistence-cassandra[] -->
<build>
<plugins>
@@ -187,9 +202,9 @@
</plugin>
<plugin>
- <groupId>com.lightbend.akka.grpc</groupId>
- <artifactId>akka-grpc-maven-plugin</artifactId>
- <version>${akka-grpc-maven-plugin.version}</version>
+ <groupId>org.apache.pekko</groupId>
+ <artifactId>pekko-grpc-maven-plugin</artifactId>
+ <version>${pekko-grpc.version}</version>
<configuration>
<language>Java</language>
</configuration>
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/CborSerializable.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/CborSerializable.java
index e07fe714..e71e95b8 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/CborSerializable.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/CborSerializable.java
@@ -2,6 +2,6 @@ package shopping.cart;
/**
* Marker trait for serialization with Jackson CBOR. Enabled in
serialization.conf
- * `akka.actor.serialization-bindings` (via application.conf).
+ * `pekko.actor.serialization-bindings` (via application.conf).
*/
public interface CborSerializable {}
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ItemPopularityProjection.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ItemPopularityProjection.java
index 0ba050a7..6f9f556c 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ItemPopularityProjection.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ItemPopularityProjection.java
@@ -1,19 +1,19 @@
// tag::projection[]
package shopping.cart;
-import akka.actor.typed.ActorSystem;
-import akka.cluster.sharding.typed.ShardedDaemonProcessSettings;
-import akka.cluster.sharding.typed.javadsl.ShardedDaemonProcess;
-import akka.persistence.cassandra.query.javadsl.CassandraReadJournal;
-import akka.persistence.query.Offset;
-import akka.projection.ProjectionBehavior;
-import akka.projection.ProjectionId;
-import akka.projection.cassandra.javadsl.CassandraProjection;
-import akka.projection.eventsourced.EventEnvelope;
-import akka.projection.eventsourced.javadsl.EventSourcedProvider;
-import akka.projection.javadsl.AtLeastOnceProjection;
-import akka.projection.javadsl.SourceProvider;
import java.util.Optional;
+import org.apache.pekko.actor.typed.ActorSystem;
+import org.apache.pekko.cluster.sharding.typed.ShardedDaemonProcessSettings;
+import org.apache.pekko.cluster.sharding.typed.javadsl.ShardedDaemonProcess;
+import
org.apache.pekko.persistence.cassandra.query.javadsl.CassandraReadJournal;
+import org.apache.pekko.persistence.query.Offset;
+import org.apache.pekko.projection.ProjectionBehavior;
+import org.apache.pekko.projection.ProjectionId;
+import org.apache.pekko.projection.cassandra.javadsl.CassandraProjection;
+import org.apache.pekko.projection.eventsourced.EventEnvelope;
+import org.apache.pekko.projection.eventsourced.javadsl.EventSourcedProvider;
+import org.apache.pekko.projection.javadsl.AtLeastOnceProjection;
+import org.apache.pekko.projection.javadsl.SourceProvider;
public final class ItemPopularityProjection {
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ItemPopularityProjectionHandler.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ItemPopularityProjectionHandler.java
index 88c21986..200e32a4 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ItemPopularityProjectionHandler.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ItemPopularityProjectionHandler.java
@@ -1,11 +1,11 @@
// tag::handler[]
package shopping.cart;
-import akka.Done;
-import akka.projection.eventsourced.EventEnvelope;
-import akka.projection.javadsl.Handler;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionStage;
+import org.apache.pekko.Done;
+import org.apache.pekko.projection.eventsourced.EventEnvelope;
+import org.apache.pekko.projection.javadsl.Handler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ItemPopularityRepository.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ItemPopularityRepository.java
index d3561ddf..0c7a3ef3 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ItemPopularityRepository.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ItemPopularityRepository.java
@@ -1,8 +1,8 @@
package shopping.cart;
-import akka.Done;
import java.util.Optional;
import java.util.concurrent.CompletionStage;
+import org.apache.pekko.Done;
public interface ItemPopularityRepository {
CompletionStage<Done> update(String itemId, int delta);
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ItemPopularityRepositoryImpl.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ItemPopularityRepositoryImpl.java
index 9284d5d9..8f938898 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ItemPopularityRepositoryImpl.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ItemPopularityRepositoryImpl.java
@@ -1,9 +1,9 @@
package shopping.cart;
-import akka.Done;
-import akka.stream.alpakka.cassandra.javadsl.CassandraSession;
import java.util.Optional;
import java.util.concurrent.CompletionStage;
+import org.apache.pekko.Done;
+import org.apache.pekko.stream.connectors.cassandra.javadsl.CassandraSession;
public final class ItemPopularityRepositoryImpl implements
ItemPopularityRepository {
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/Main.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/Main.java
index 57d2b43d..edc4b246 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/Main.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/Main.java
@@ -1,13 +1,13 @@
package shopping.cart;
-import akka.actor.typed.ActorSystem;
-import akka.actor.typed.javadsl.Behaviors;
-import akka.grpc.GrpcClientSettings;
-import akka.management.cluster.bootstrap.ClusterBootstrap;
-import akka.management.javadsl.AkkaManagement;
-import akka.stream.alpakka.cassandra.javadsl.CassandraSession;
-import akka.stream.alpakka.cassandra.javadsl.CassandraSessionRegistry;
import com.typesafe.config.Config;
+import org.apache.pekko.actor.typed.ActorSystem;
+import org.apache.pekko.actor.typed.javadsl.Behaviors;
+import org.apache.pekko.grpc.GrpcClientSettings;
+import org.apache.pekko.management.cluster.bootstrap.ClusterBootstrap;
+import org.apache.pekko.management.javadsl.PekkoManagement;
+import org.apache.pekko.stream.connectors.cassandra.javadsl.CassandraSession;
+import
org.apache.pekko.stream.connectors.cassandra.javadsl.CassandraSessionRegistry;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import shopping.cart.proto.ShoppingCartService;
@@ -29,18 +29,18 @@ public class Main {
}
public static void init(ActorSystem<Void> system, ShoppingOrderService
orderService) {
- AkkaManagement.get(system).start();
+ PekkoManagement.get(system).start();
ClusterBootstrap.get(system).start();
ShoppingCart.init(system);
// tag::ItemPopularityProjection[]
CassandraSession session =
-
CassandraSessionRegistry.get(system).sessionFor("akka.persistence.cassandra");
// <1>
+
CassandraSessionRegistry.get(system).sessionFor("pekko.persistence.cassandra");
// <1>
// use same keyspace for the item_popularity table as the offset store
Config config = system.settings().config();
String itemPopularityKeyspace =
- config.getString("akka.projection.cassandra.offset-store.keyspace");
+ config.getString("pekko.projection.cassandra.offset-store.keyspace");
ItemPopularityRepository itemPopularityRepository =
new ItemPopularityRepositoryImpl(session, itemPopularityKeyspace); //
<2>
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/PublishEventsProjection.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/PublishEventsProjection.java
index 65f95e95..31a68577 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/PublishEventsProjection.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/PublishEventsProjection.java
@@ -1,23 +1,23 @@
package shopping.cart;
-import akka.actor.CoordinatedShutdown;
-import akka.actor.typed.ActorSystem;
-import akka.cluster.sharding.typed.ShardedDaemonProcessSettings;
-import akka.cluster.sharding.typed.javadsl.ShardedDaemonProcess;
-import akka.kafka.ProducerSettings;
-import akka.kafka.javadsl.SendProducer;
-import akka.persistence.cassandra.query.javadsl.CassandraReadJournal;
-import akka.persistence.query.Offset;
-import akka.projection.ProjectionBehavior;
-import akka.projection.ProjectionId;
-import akka.projection.cassandra.javadsl.CassandraProjection;
-import akka.projection.eventsourced.EventEnvelope;
-import akka.projection.eventsourced.javadsl.EventSourcedProvider;
-import akka.projection.javadsl.AtLeastOnceProjection;
-import akka.projection.javadsl.SourceProvider;
import java.util.Optional;
import org.apache.kafka.common.serialization.ByteArraySerializer;
import org.apache.kafka.common.serialization.StringSerializer;
+import org.apache.pekko.actor.CoordinatedShutdown;
+import org.apache.pekko.actor.typed.ActorSystem;
+import org.apache.pekko.cluster.sharding.typed.ShardedDaemonProcessSettings;
+import org.apache.pekko.cluster.sharding.typed.javadsl.ShardedDaemonProcess;
+import org.apache.pekko.kafka.ProducerSettings;
+import org.apache.pekko.kafka.javadsl.SendProducer;
+import
org.apache.pekko.persistence.cassandra.query.javadsl.CassandraReadJournal;
+import org.apache.pekko.persistence.query.Offset;
+import org.apache.pekko.projection.ProjectionBehavior;
+import org.apache.pekko.projection.ProjectionId;
+import org.apache.pekko.projection.cassandra.javadsl.CassandraProjection;
+import org.apache.pekko.projection.eventsourced.EventEnvelope;
+import org.apache.pekko.projection.eventsourced.javadsl.EventSourcedProvider;
+import org.apache.pekko.projection.javadsl.AtLeastOnceProjection;
+import org.apache.pekko.projection.javadsl.SourceProvider;
public final class PublishEventsProjection {
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/PublishEventsProjectionHandler.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/PublishEventsProjectionHandler.java
index ab84ee40..ad553d38 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/PublishEventsProjectionHandler.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/PublishEventsProjectionHandler.java
@@ -1,16 +1,16 @@
// tag::handler[]
package shopping.cart;
-import static akka.Done.done;
+import static org.apache.pekko.Done.done;
-import akka.Done;
-import akka.kafka.javadsl.SendProducer;
-import akka.projection.eventsourced.EventEnvelope;
-import akka.projection.javadsl.Handler;
import com.google.protobuf.Any;
import com.google.protobuf.ByteString;
import java.util.concurrent.CompletionStage;
import org.apache.kafka.clients.producer.ProducerRecord;
+import org.apache.pekko.Done;
+import org.apache.pekko.kafka.javadsl.SendProducer;
+import org.apache.pekko.projection.eventsourced.EventEnvelope;
+import org.apache.pekko.projection.javadsl.Handler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/SendOrderProjection.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/SendOrderProjection.java
index 8ce74c04..f58913f7 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/SendOrderProjection.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/SendOrderProjection.java
@@ -1,18 +1,18 @@
package shopping.cart;
-import akka.actor.typed.ActorSystem;
-import akka.cluster.sharding.typed.ShardedDaemonProcessSettings;
-import akka.cluster.sharding.typed.javadsl.ShardedDaemonProcess;
-import akka.persistence.cassandra.query.javadsl.CassandraReadJournal;
-import akka.persistence.query.Offset;
-import akka.projection.ProjectionBehavior;
-import akka.projection.ProjectionId;
-import akka.projection.cassandra.javadsl.CassandraProjection;
-import akka.projection.eventsourced.EventEnvelope;
-import akka.projection.eventsourced.javadsl.EventSourcedProvider;
-import akka.projection.javadsl.AtLeastOnceProjection;
-import akka.projection.javadsl.SourceProvider;
import java.util.Optional;
+import org.apache.pekko.actor.typed.ActorSystem;
+import org.apache.pekko.cluster.sharding.typed.ShardedDaemonProcessSettings;
+import org.apache.pekko.cluster.sharding.typed.javadsl.ShardedDaemonProcess;
+import
org.apache.pekko.persistence.cassandra.query.javadsl.CassandraReadJournal;
+import org.apache.pekko.persistence.query.Offset;
+import org.apache.pekko.projection.ProjectionBehavior;
+import org.apache.pekko.projection.ProjectionId;
+import org.apache.pekko.projection.cassandra.javadsl.CassandraProjection;
+import org.apache.pekko.projection.eventsourced.EventEnvelope;
+import org.apache.pekko.projection.eventsourced.javadsl.EventSourcedProvider;
+import org.apache.pekko.projection.javadsl.AtLeastOnceProjection;
+import org.apache.pekko.projection.javadsl.SourceProvider;
import shopping.order.proto.ShoppingOrderService;
public class SendOrderProjection {
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/SendOrderProjectionHandler.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/SendOrderProjectionHandler.java
index 8b032108..a188af97 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/SendOrderProjectionHandler.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/SendOrderProjectionHandler.java
@@ -1,18 +1,18 @@
package shopping.cart;
-import static akka.Done.done;
+import static org.apache.pekko.Done.done;
-import akka.Done;
-import akka.actor.typed.ActorSystem;
-import akka.cluster.sharding.typed.javadsl.ClusterSharding;
-import akka.cluster.sharding.typed.javadsl.EntityRef;
-import akka.projection.eventsourced.EventEnvelope;
-import akka.projection.javadsl.Handler;
import java.time.Duration;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionStage;
import java.util.stream.Collectors;
+import org.apache.pekko.Done;
+import org.apache.pekko.actor.typed.ActorSystem;
+import org.apache.pekko.cluster.sharding.typed.javadsl.ClusterSharding;
+import org.apache.pekko.cluster.sharding.typed.javadsl.EntityRef;
+import org.apache.pekko.projection.eventsourced.EventEnvelope;
+import org.apache.pekko.projection.javadsl.Handler;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import shopping.order.proto.Item;
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ShoppingCart.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ShoppingCart.java
index d4c92b87..13ff4165 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ShoppingCart.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ShoppingCart.java
@@ -1,20 +1,20 @@
package shopping.cart;
-import akka.actor.typed.ActorRef;
-import akka.actor.typed.ActorSystem;
-import akka.actor.typed.Behavior;
-import akka.actor.typed.SupervisorStrategy;
-import akka.actor.typed.javadsl.Behaviors;
-import akka.cluster.sharding.typed.javadsl.ClusterSharding;
-import akka.cluster.sharding.typed.javadsl.Entity;
-import akka.cluster.sharding.typed.javadsl.EntityTypeKey;
-import akka.pattern.StatusReply;
-import akka.persistence.typed.PersistenceId;
-import akka.persistence.typed.javadsl.*;
import com.fasterxml.jackson.annotation.JsonCreator;
import java.time.Duration;
import java.time.Instant;
import java.util.*;
+import org.apache.pekko.actor.typed.ActorRef;
+import org.apache.pekko.actor.typed.ActorSystem;
+import org.apache.pekko.actor.typed.Behavior;
+import org.apache.pekko.actor.typed.SupervisorStrategy;
+import org.apache.pekko.actor.typed.javadsl.Behaviors;
+import org.apache.pekko.cluster.sharding.typed.javadsl.ClusterSharding;
+import org.apache.pekko.cluster.sharding.typed.javadsl.Entity;
+import org.apache.pekko.cluster.sharding.typed.javadsl.EntityTypeKey;
+import org.apache.pekko.pattern.StatusReply;
+import org.apache.pekko.persistence.typed.PersistenceId;
+import org.apache.pekko.persistence.typed.javadsl.*;
/**
* This is an event sourced actor (`EventSourcedBehavior`). An entity managed
by Cluster Sharding.
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ShoppingCartServer.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ShoppingCartServer.java
index 20157537..3347f85c 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ShoppingCartServer.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ShoppingCartServer.java
@@ -1,17 +1,17 @@
package shopping.cart;
-import akka.actor.typed.ActorSystem;
-import akka.grpc.javadsl.ServerReflection;
-import akka.grpc.javadsl.ServiceHandler;
-import akka.http.javadsl.Http;
-import akka.http.javadsl.ServerBinding;
-import akka.http.javadsl.model.HttpRequest;
-import akka.http.javadsl.model.HttpResponse;
-import akka.japi.function.Function;
import java.net.InetSocketAddress;
import java.time.Duration;
import java.util.Collections;
import java.util.concurrent.CompletionStage;
+import org.apache.pekko.actor.typed.ActorSystem;
+import org.apache.pekko.grpc.javadsl.ServerReflection;
+import org.apache.pekko.grpc.javadsl.ServiceHandler;
+import org.apache.pekko.http.javadsl.Http;
+import org.apache.pekko.http.javadsl.ServerBinding;
+import org.apache.pekko.http.javadsl.model.HttpRequest;
+import org.apache.pekko.http.javadsl.model.HttpResponse;
+import org.apache.pekko.japi.function.Function;
import shopping.cart.proto.ShoppingCartService;
import shopping.cart.proto.ShoppingCartServiceHandlerFactory;
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ShoppingCartServiceImpl.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ShoppingCartServiceImpl.java
index e392af31..2bc62085 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ShoppingCartServiceImpl.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/java/shopping/cart/ShoppingCartServiceImpl.java
@@ -1,15 +1,15 @@
package shopping.cart;
-import akka.actor.typed.ActorSystem;
-import akka.cluster.sharding.typed.javadsl.ClusterSharding;
-import akka.cluster.sharding.typed.javadsl.EntityRef;
-import akka.grpc.GrpcServiceException;
import io.grpc.Status;
import java.time.Duration;
import java.util.List;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.TimeoutException;
import java.util.stream.Collectors;
+import org.apache.pekko.actor.typed.ActorSystem;
+import org.apache.pekko.cluster.sharding.typed.javadsl.ClusterSharding;
+import org.apache.pekko.cluster.sharding.typed.javadsl.EntityRef;
+import org.apache.pekko.grpc.GrpcServiceException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import shopping.cart.proto.*;
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/application.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/application.conf
index f878dbfd..6877a31c 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/application.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/application.conf
@@ -4,7 +4,7 @@ include "serialization"
include "persistence"
include "kafka"
-akka {
+pekko {
loglevel = DEBUG
}
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/cluster.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/cluster.conf
index e982dfe1..c75faa0c 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/cluster.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/cluster.conf
@@ -1,4 +1,4 @@
-akka {
+pekko {
actor.provider = cluster
remote.artery {
@@ -6,7 +6,7 @@ akka {
}
cluster {
- downing-provider-class = "akka.cluster.sbr.SplitBrainResolverProvider"
+ downing-provider-class =
"org.apache.pekko.cluster.sbr.SplitBrainResolverProvider"
shutdown-after-unsuccessful-join-seed-nodes = 120s
@@ -17,7 +17,7 @@ akka {
}
}
-akka.management {
+pekko.management {
http {
port = 8558
port = ${?HTTP_MGMT_PORT}
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/grpc.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/grpc.conf
index 15b34d62..ad1de437 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/grpc.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/grpc.conf
@@ -1,4 +1,4 @@
-akka.http.server.preview.enable-http2 = on
+pekko.http.server.preview.enable-http2 = on
shopping-cart-service {
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/kafka.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/kafka.conf
index 9b020371..bebf0b3b 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/kafka.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/kafka.conf
@@ -4,15 +4,15 @@ shopping-cart-service {
}
-# common config for akka.kafka.producer.kafka-clients and
akka.kafka.consumer.kafka-clients
+# common config for pekko.kafka.producer.kafka-clients and
pekko.kafka.consumer.kafka-clients
kafka-connection-settings {
# This and other connection settings may have to be changed depending on
environment.
bootstrap.servers = "localhost:9092"
}
-akka.kafka.producer {
+pekko.kafka.producer {
kafka-clients = ${kafka-connection-settings}
}
-akka.kafka.consumer {
+pekko.kafka.consumer {
kafka-clients = ${kafka-connection-settings}
}
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/local-shared.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/local-shared.conf
index 417b63a6..b6628388 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/local-shared.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/local-shared.conf
@@ -1,8 +1,8 @@
shopping-cart-service.grpc.interface = "127.0.0.1"
-akka.remote.artery.canonical.hostname = "127.0.0.1"
-akka.management.http.hostname = "127.0.0.1"
+pekko.remote.artery.canonical.hostname = "127.0.0.1"
+pekko.management.http.hostname = "127.0.0.1"
-akka.management.cluster.bootstrap.contact-point-discovery {
+pekko.management.cluster.bootstrap.contact-point-discovery {
service-name = "shopping-cart-service"
discovery-method = config
# boostrap filters ports with the same IP assuming they are previous
instances running on the same node
@@ -15,7 +15,7 @@ akka.management.cluster.bootstrap.contact-point-discovery {
contact-with-all-contact-points = false
}
-akka.discovery.config.services {
+pekko.discovery.config.services {
"shopping-cart-service" {
endpoints = [
{host = "127.0.0.1", port = 9101}
@@ -26,14 +26,14 @@ akka.discovery.config.services {
}
// tag::kafka[]
-# common config for akka.kafka.producer.kafka-clients and
akka.kafka.consumer.kafka-clients
+# common config for pekko.kafka.producer.kafka-clients and
pekko.kafka.consumer.kafka-clients
kafka-connection-settings {
bootstrap.servers = "localhost:9092"
}
-akka.kafka.producer {
+pekko.kafka.producer {
kafka-clients = ${kafka-connection-settings}
}
-akka.kafka.consumer {
+pekko.kafka.consumer {
kafka-clients = ${kafka-connection-settings}
}
// end::kafka[]
@@ -45,5 +45,5 @@ shopping-order-service.port = 8301
// tag::projection-delay[]
# for reduced Projection latency
-akka.persistence.cassandra.events-by-tag.eventual-consistency-delay = 200 ms
+pekko.persistence.cassandra.events-by-tag.eventual-consistency-delay = 200 ms
// end::projection-delay[]
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/local1.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/local1.conf
index 20e3b819..9e9a6f43 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/local1.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/local1.conf
@@ -3,6 +3,6 @@ include "local-shared"
shopping-cart-service.grpc.port = 8101
-akka.remote.artery.canonical.port = 2551
-akka.management.http.port = 9101
+pekko.remote.artery.canonical.port = 2551
+pekko.management.http.port = 9101
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/local2.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/local2.conf
index fe3d6a5d..41672bbd 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/local2.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/local2.conf
@@ -3,5 +3,5 @@ include "local-shared"
shopping-cart-service.grpc.port = 8102
-akka.management.http.port = 9102
-akka.remote.artery.canonical.port = 2552
+pekko.management.http.port = 9102
+pekko.remote.artery.canonical.port = 2552
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/local3.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/local3.conf
index f33c855f..a54e6d5b 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/local3.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/local3.conf
@@ -3,5 +3,5 @@ include "local-shared"
shopping-cart-service.grpc.port = 8103
-akka.remote.artery.canonical.port = 2553
-akka.management.http.port = 9103
+pekko.remote.artery.canonical.port = 2553
+pekko.management.http.port = 9103
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/logback.xml
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/logback.xml
index cc3e40e0..93f2d29a 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/logback.xml
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/logback.xml
@@ -1,7 +1,7 @@
<configuration>
<appender name="STDOUT" target="System.out"
class="ch.qos.logback.core.ConsoleAppender">
<encoder>
- <pattern>[%date{ISO8601}] [%level] [%logger] [%X{akkaAddress}]
[%marker] [%thread] - %msg%n</pattern>
+ <pattern>[%date{ISO8601}] [%level] [%logger] [%X{pekkoAddress}]
[%marker] [%thread] - %msg%n</pattern>
</encoder>
</appender>
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/persistence.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/persistence.conf
index 4326f94b..18ad39e9 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/persistence.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/persistence.conf
@@ -1,10 +1,10 @@
-# tag::akka-persistence-cassandra[]
-akka {
+# tag::pekko-persistence-cassandra[]
+pekko {
# use Cassandra to store both snapshots and the events of the persistent
actors
persistence {
- journal.plugin = "akka.persistence.cassandra.journal"
- journal.auto-start-journals = ["akka.persistence.cassandra.journal"]
- snapshot-store.plugin = "akka.persistence.cassandra.snapshot"
+ journal.plugin = "pekko.persistence.cassandra.journal"
+ journal.auto-start-journals = ["pekko.persistence.cassandra.journal"]
+ snapshot-store.plugin = "pekko.persistence.cassandra.snapshot"
cassandra {
events-by-tag {
@@ -29,21 +29,21 @@ akka {
datastax-java-driver {
advanced.reconnect-on-init = on
}
-# end::akka-persistence-cassandra[]
+# end::pekko-persistence-cassandra[]
-# tag::akka-projection-cassandra[]
-akka.projection {
+# tag::pekko-projection-cassandra[]
+pekko.projection {
cassandra.offset-store.keyspace = "shoppingcartservice"
# use same Cassandra session config as for the journal
- cassandra.session-config-path = "akka.persistence.cassandra"
+ cassandra.session-config-path = "pekko.persistence.cassandra"
}
-# end::akka-projection-cassandra[]
+# end::pekko-projection-cassandra[]
# tag::healthchecks-for-cassandra[]
-akka.management {
+pekko.management {
health-checks {
readiness-checks {
- akka-persistence-cassandra =
"akka.persistence.cassandra.healthcheck.CassandraHealthCheck"
+ pekko-persistence-cassandra =
"org.apache.pekko.persistence.cassandra.healthcheck.CassandraHealthCheck"
}
}
}
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/serialization.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/serialization.conf
index 7d153b9c..74f6bdcf 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/serialization.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/main/resources/serialization.conf
@@ -1,3 +1,3 @@
-akka.actor.serialization-bindings {
+pekko.actor.serialization-bindings {
"shopping.cart.CborSerializable" = jackson-cbor
}
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/CreateTableTestUtils.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/CreateTableTestUtils.java
index 2382f8d4..f587ae74 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/CreateTableTestUtils.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/CreateTableTestUtils.java
@@ -2,10 +2,10 @@ package shopping.cart;
import static java.util.concurrent.TimeUnit.SECONDS;
-import akka.actor.typed.ActorSystem;
-import akka.projection.cassandra.javadsl.CassandraProjection;
-import akka.stream.alpakka.cassandra.javadsl.CassandraSession;
-import akka.stream.alpakka.cassandra.javadsl.CassandraSessionRegistry;
+import org.apache.pekko.actor.typed.ActorSystem;
+import org.apache.pekko.projection.cassandra.javadsl.CassandraProjection;
+import org.apache.pekko.stream.connectors.cassandra.javadsl.CassandraSession;
+import
org.apache.pekko.stream.connectors.cassandra.javadsl.CassandraSessionRegistry;
import org.slf4j.LoggerFactory;
public class CreateTableTestUtils {
@@ -15,9 +15,9 @@ public class CreateTableTestUtils {
// use same keyspace for the item_popularity table as the offset store
String keyspace =
-
system.settings().config().getString("akka.projection.cassandra.offset-store.keyspace");
+
system.settings().config().getString("pekko.projection.cassandra.offset-store.keyspace");
CassandraSession session =
-
CassandraSessionRegistry.get(system).sessionFor("akka.persistence.cassandra");
+
CassandraSessionRegistry.get(system).sessionFor("pekko.persistence.cassandra");
session
.executeDDL(
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/IntegrationTest.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/IntegrationTest.java
index 55f39e6d..95d199b5 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/IntegrationTest.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/IntegrationTest.java
@@ -4,18 +4,6 @@ import static java.util.concurrent.TimeUnit.SECONDS;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
-import akka.actor.CoordinatedShutdown;
-import akka.actor.testkit.typed.javadsl.ActorTestKit;
-import akka.actor.testkit.typed.javadsl.TestProbe;
-import akka.actor.typed.ActorSystem;
-import akka.cluster.MemberStatus;
-import akka.cluster.typed.Cluster;
-import akka.grpc.GrpcClientSettings;
-import akka.kafka.ConsumerSettings;
-import akka.kafka.Subscriptions;
-import akka.kafka.javadsl.Consumer;
-import akka.persistence.testkit.javadsl.PersistenceInit;
-import akka.testkit.SocketUtil;
import com.google.protobuf.Any;
import com.google.protobuf.CodedInputStream;
import com.typesafe.config.Config;
@@ -30,6 +18,18 @@ import java.util.concurrent.CompletionStage;
import java.util.stream.Collectors;
import org.apache.kafka.common.serialization.ByteArrayDeserializer;
import org.apache.kafka.common.serialization.StringDeserializer;
+import org.apache.pekko.actor.CoordinatedShutdown;
+import org.apache.pekko.actor.testkit.typed.javadsl.ActorTestKit;
+import org.apache.pekko.actor.testkit.typed.javadsl.TestProbe;
+import org.apache.pekko.actor.typed.ActorSystem;
+import org.apache.pekko.cluster.MemberStatus;
+import org.apache.pekko.cluster.typed.Cluster;
+import org.apache.pekko.grpc.GrpcClientSettings;
+import org.apache.pekko.kafka.ConsumerSettings;
+import org.apache.pekko.kafka.Subscriptions;
+import org.apache.pekko.kafka.javadsl.Consumer;
+import org.apache.pekko.persistence.testkit.javadsl.PersistenceInit;
+import org.apache.pekko.testkit.SocketUtil;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
@@ -50,13 +50,13 @@ public class IntegrationTest {
private static Config sharedConfig() {
return ConfigFactory.parseString(
- "akka.persistence.cassandra.journal.keyspace = "
+ "pekko.persistence.cassandra.journal.keyspace = "
+ KEYSPACE
+ "\n"
- + "akka.persistence.cassandra.snapshot.keyspace = "
+ + "pekko.persistence.cassandra.snapshot.keyspace = "
+ KEYSPACE
+ "\n"
- + "akka.projection.cassandra.offset-store.keyspace = "
+ + "pekko.projection.cassandra.offset-store.keyspace = "
+ KEYSPACE
+ "\n"
+ "shopping-cart-service.kafka.topic = \"shopping-cart-events_"
@@ -71,10 +71,10 @@ public class IntegrationTest {
"shopping-cart-service.grpc.port = "
+ grcpPort
+ "\n"
- + "akka.management.http.port = "
+ + "pekko.management.http.port = "
+ managementPorts.get(managementPortIndex)
+ "\n"
- + "akka.discovery.config.services.shopping-cart-service.endpoints
= [\n"
+ + "pekko.discovery.config.services.shopping-cart-service.endpoints
= [\n"
+ " { host = \"127.0.0.1\", port = "
+ managementPorts.get(0)
+ "},\n"
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/ItemPopularityIntegrationTest.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/ItemPopularityIntegrationTest.java
index 197fe61c..67abe5ff 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/ItemPopularityIntegrationTest.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/ItemPopularityIntegrationTest.java
@@ -4,22 +4,22 @@ import static java.util.concurrent.TimeUnit.SECONDS;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
-import akka.actor.testkit.typed.javadsl.TestKitJunitResource;
-import akka.actor.testkit.typed.javadsl.TestProbe;
-import akka.actor.typed.ActorSystem;
-import akka.cluster.MemberStatus;
-import akka.cluster.sharding.typed.javadsl.ClusterSharding;
-import akka.cluster.sharding.typed.javadsl.EntityRef;
-import akka.cluster.typed.Cluster;
-import akka.cluster.typed.Join;
-import akka.persistence.testkit.javadsl.PersistenceInit;
-import akka.stream.alpakka.cassandra.javadsl.CassandraSession;
-import akka.stream.alpakka.cassandra.javadsl.CassandraSessionRegistry;
import com.typesafe.config.Config;
import com.typesafe.config.ConfigFactory;
import java.time.Duration;
import java.util.Optional;
import java.util.concurrent.CompletionStage;
+import org.apache.pekko.actor.testkit.typed.javadsl.TestKitJunitResource;
+import org.apache.pekko.actor.testkit.typed.javadsl.TestProbe;
+import org.apache.pekko.actor.typed.ActorSystem;
+import org.apache.pekko.cluster.MemberStatus;
+import org.apache.pekko.cluster.sharding.typed.javadsl.ClusterSharding;
+import org.apache.pekko.cluster.sharding.typed.javadsl.EntityRef;
+import org.apache.pekko.cluster.typed.Cluster;
+import org.apache.pekko.cluster.typed.Join;
+import org.apache.pekko.persistence.testkit.javadsl.PersistenceInit;
+import org.apache.pekko.stream.connectors.cassandra.javadsl.CassandraSession;
+import
org.apache.pekko.stream.connectors.cassandra.javadsl.CassandraSessionRegistry;
import org.junit.BeforeClass;
import org.junit.ClassRule;
import org.junit.Test;
@@ -30,13 +30,13 @@ public class ItemPopularityIntegrationTest {
private static Config config() {
return ConfigFactory.parseString(
- "akka.persistence.cassandra.journal.keyspace = "
+ "pekko.persistence.cassandra.journal.keyspace = "
+ KEYSPACE
+ "\n"
- + "akka.persistence.cassandra.snapshot.keyspace = "
+ + "pekko.persistence.cassandra.snapshot.keyspace = "
+ KEYSPACE
+ "\n"
- + "akka.projection.cassandra.offset-store.keyspace = "
+ + "pekko.projection.cassandra.offset-store.keyspace = "
+ KEYSPACE
+ "\n")
.withFallback(ConfigFactory.load("item-popularity-integration-test.conf"));
@@ -57,9 +57,9 @@ public class ItemPopularityIntegrationTest {
// use same keyspace for the item_popularity table as the offset store
CassandraSession session =
-
CassandraSessionRegistry.get(system).sessionFor("akka.persistence.cassandra");
+
CassandraSessionRegistry.get(system).sessionFor("pekko.persistence.cassandra");
String itemPopularityKeyspace =
-
system.settings().config().getString("akka.projection.cassandra.offset-store.keyspace");
+
system.settings().config().getString("pekko.projection.cassandra.offset-store.keyspace");
ShoppingCart.init(system);
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/ItemPopularityProjectionTest.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/ItemPopularityProjectionTest.java
index 04d264ac..69ffa270 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/ItemPopularityProjectionTest.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/ItemPopularityProjectionTest.java
@@ -1,18 +1,8 @@
package shopping.cart;
-import static akka.Done.done;
+import static org.apache.pekko.Done.done;
import static org.junit.Assert.assertEquals;
-import akka.Done;
-import akka.NotUsed;
-import akka.actor.testkit.typed.javadsl.TestKitJunitResource;
-import akka.persistence.query.Offset;
-import akka.projection.ProjectionId;
-import akka.projection.eventsourced.EventEnvelope;
-import akka.projection.testkit.javadsl.ProjectionTestKit;
-import akka.projection.testkit.javadsl.TestProjection;
-import akka.projection.testkit.javadsl.TestSourceProvider;
-import akka.stream.javadsl.Source;
import java.time.Instant;
import java.util.Arrays;
import java.util.HashMap;
@@ -20,6 +10,16 @@ import java.util.Map;
import java.util.Optional;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionStage;
+import org.apache.pekko.Done;
+import org.apache.pekko.NotUsed;
+import org.apache.pekko.actor.testkit.typed.javadsl.TestKitJunitResource;
+import org.apache.pekko.persistence.query.Offset;
+import org.apache.pekko.projection.ProjectionId;
+import org.apache.pekko.projection.eventsourced.EventEnvelope;
+import org.apache.pekko.projection.testkit.javadsl.ProjectionTestKit;
+import org.apache.pekko.projection.testkit.javadsl.TestProjection;
+import org.apache.pekko.projection.testkit.javadsl.TestSourceProvider;
+import org.apache.pekko.stream.javadsl.Source;
import org.junit.ClassRule;
import org.junit.Test;
@@ -60,7 +60,7 @@ public class ItemPopularityProjectionTest {
createEnvelope(
new ShoppingCart.CheckedOut("a7079",
Instant.parse("2020-01-01T12:00:00.00Z")),
2L),
- createEnvelope(new ShoppingCart.ItemAdded("0d12d", "akka
t-shirt", 1), 3L),
+ createEnvelope(new ShoppingCart.ItemAdded("0d12d", "pekko
t-shirt", 1), 3L),
createEnvelope(new ShoppingCart.ItemAdded("0d12d", "skis", 1),
4L),
createEnvelope(new ShoppingCart.ItemRemoved("0d12d", "skis",
1), 5L),
createEnvelope(
@@ -82,7 +82,7 @@ public class ItemPopularityProjectionTest {
() -> {
assertEquals(3, repository.counts.size());
assertEquals(2L, repository.counts.get("bowling shoes").longValue());
- assertEquals(1L, repository.counts.get("akka t-shirt").longValue());
+ assertEquals(1L, repository.counts.get("pekko t-shirt").longValue());
assertEquals(0L, repository.counts.get("skis").longValue());
});
}
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/ShoppingCartTest.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/ShoppingCartTest.java
index 9150bc87..e028fc23 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/ShoppingCartTest.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/java/shopping/cart/ShoppingCartTest.java
@@ -1,12 +1,12 @@
package shopping.cart;
-import static
akka.persistence.testkit.javadsl.EventSourcedBehaviorTestKit.CommandResultWithReply;
+import static
org.apache.pekko.persistence.testkit.javadsl.EventSourcedBehaviorTestKit.CommandResultWithReply;
import static org.junit.Assert.*;
-import akka.actor.testkit.typed.javadsl.TestKitJunitResource;
-import akka.pattern.StatusReply;
-import akka.persistence.testkit.javadsl.EventSourcedBehaviorTestKit;
import com.typesafe.config.ConfigFactory;
+import org.apache.pekko.actor.testkit.typed.javadsl.TestKitJunitResource;
+import org.apache.pekko.pattern.StatusReply;
+import
org.apache.pekko.persistence.testkit.javadsl.EventSourcedBehaviorTestKit;
import org.junit.Before;
import org.junit.ClassRule;
import org.junit.Test;
@@ -19,7 +19,7 @@ public class ShoppingCartTest {
public static final TestKitJunitResource testKit =
new TestKitJunitResource(
ConfigFactory.parseString(
- "akka.actor.serialization-bindings {\n"
+ "pekko.actor.serialization-bindings {\n"
+ " \"shopping.cart.CborSerializable\" = jackson-cbor\n"
+ "}")
.withFallback(EventSourcedBehaviorTestKit.config()));
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/resources/integration-test.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/resources/integration-test.conf
index 6e270382..f711bafb 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/resources/integration-test.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/resources/integration-test.conf
@@ -1,13 +1,13 @@
include "local1"
-akka.cluster.jmx.multi-mbeans-in-same-jvm = on
+pekko.cluster.jmx.multi-mbeans-in-same-jvm = on
-akka.remote.artery.canonical {
+pekko.remote.artery.canonical {
hostname = "127.0.0.1"
port = 0
}
-akka.persistence.cassandra {
+pekko.persistence.cassandra {
events-by-tag {
eventual-consistency-delay = 200ms
}
@@ -28,17 +28,17 @@ datastax-java-driver {
advanced.session-leak.threshold = 10
}
-// akka.projection.cassandra.offset-store.keyspace = set by test
+// pekko.projection.cassandra.offset-store.keyspace = set by test
// shopping-cart-service.kafka.topic = set by test
-akka.kafka.consumer {
+pekko.kafka.consumer {
kafka-clients {
auto.offset.reset = "earliest"
}
}
-akka.actor.testkit.typed {
+pekko.actor.testkit.typed {
single-expect-default = 5s
filter-leeway = 5s
system-shutdown-default = 30s
@@ -49,11 +49,11 @@ shopping-cart-service.grpc {
// port = set by test per fixture
}
-// akka.management.http.port = set by test per fixture
-// akka.discovery.config.services."shoppingcartservice".endpoints = set by test
+// pekko.management.http.port = set by test per fixture
+// pekko.discovery.config.services."shoppingcartservice".endpoints = set by
test
# don't self-join until all 3 have been started and probed sucessfully
-akka.management.cluster.bootstrap.contact-point-discovery {
+pekko.management.cluster.bootstrap.contact-point-discovery {
required-contact-point-nr = 3
contact-with-all-contact-points = true
}
\ No newline at end of file
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/resources/item-popularity-integration-test.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/resources/item-popularity-integration-test.conf
index e99cc58e..2e4de5dc 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/resources/item-popularity-integration-test.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/resources/item-popularity-integration-test.conf
@@ -1,11 +1,11 @@
include "application"
-akka.remote.artery.canonical {
+pekko.remote.artery.canonical {
hostname = "127.0.0.1"
port = 0
}
-akka.persistence.cassandra {
+pekko.persistence.cassandra {
events-by-tag {
eventual-consistency-delay = 200ms
}
@@ -26,4 +26,4 @@ datastax-java-driver {
basic.load-balancing-policy.local-datacenter = "datacenter1"
}
-// akka.projection.cassandra.offset-store.keyspace = set by test
\ No newline at end of file
+// pekko.projection.cassandra.offset-store.keyspace = set by test
\ No newline at end of file
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/resources/logback-test.xml
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/resources/logback-test.xml
index 053b04b6..b8f58bc8 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/resources/logback-test.xml
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-java/src/test/resources/logback-test.xml
@@ -2,7 +2,7 @@
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
- <pattern>[%date{ISO8601}] [%level] [%logger] [%X{akkaAddress}]
[%marker] [%thread] - %msg%n</pattern>
+ <pattern>[%date{ISO8601}] [%level] [%logger] [%X{pekkoAddress}]
[%marker] [%thread] - %msg%n</pattern>
</encoder>
</appender>
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
