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 d7c5514c migrate other how-to samples (#69)
d7c5514c is described below
commit d7c5514c696afdd077f2aa097e0b36fde4ba57f0
Author: PJ Fanning <[email protected]>
AuthorDate: Sun Dec 24 20:26:26 2023 +0100
migrate other how-to samples (#69)
* migrate other how-to samples
* Update persistence.conf
* Update persistence.conf
* Update persistence.conf
---
.../README.md | 4 +-
.../build.sbt | 86 ++++++++--------
.../project/plugins.sbt | 4 +-
.../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 +-
.../scala/shopping/cart/CborSerializable.scala | 2 +-
.../shopping/cart/ItemPopularityProjection.scala | 24 ++---
.../cart/ItemPopularityProjectionHandler.scala | 8 +-
.../shopping/cart/ItemPopularityRepository.scala | 4 +-
.../src/main/scala/shopping/cart/Main.scala | 18 ++--
.../shopping/cart/PublishEventsProjection.scala | 29 +++---
.../cart/PublishEventsProjectionHandler.scala | 10 +-
.../scala/shopping/cart/SendOrderProjection.scala | 24 ++---
.../shopping/cart/SendOrderProjectionHandler.scala | 12 +--
.../main/scala/shopping/cart/ShoppingCart.scala | 28 +++---
.../scala/shopping/cart/ShoppingCartServer.scala | 12 +--
.../shopping/cart/ShoppingCartServiceImpl.scala | 12 +--
.../src/test/resources/logback-test.xml | 2 +-
.../scala/shopping/cart/CreateTableTestUtils.scala | 10 +-
.../test/scala/shopping/cart/IntegrationSpec.scala | 40 ++++----
.../cart/ItemPopularityIntegrationSpec.scala | 24 ++---
.../cart/ItemPopularityProjectionSpec.scala | 22 ++---
.../scala/shopping/cart/ShoppingCartSpec.scala | 8 +-
.../examples/shopping-cart-service-java/pom.xml | 109 ++++++++++++---------
.../shopping/cart/ItemPopularityProjection.java | 14 +--
.../src/main/java/shopping/cart/Main.java | 12 +--
.../src/main/java/shopping/cart/ShoppingCart.java | 22 ++---
.../examples/shopping-cart-service-scala/build.sbt | 72 +++++++-------
.../project/plugins.sbt | 4 +-
.../shopping/cart/ItemPopularityProjection.scala | 14 +--
.../shopping/cart/ItemPopularityRepository.scala | 2 +-
.../src/main/scala/shopping/cart/Main.scala | 12 +--
.../main/scala/shopping/cart/ShoppingCart.scala | 13 ++-
42 files changed, 371 insertions(+), 358 deletions(-)
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/README.md
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/README.md
index 9c828971..caa5308b 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/README.md
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/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_1 cqlsh -t <
ddl-scripts/create_tables.cql
```
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/build.sbt
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/build.sbt
index 9598a596..57bb9ed1 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/build.sbt
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/build.sbt
@@ -22,17 +22,17 @@ Test / logBuffered := false
run / fork := false
Global / cancelable := false // ctrl-c
-val AkkaVersion = "2.6.20"
-val AkkaHttpVersion = "10.2.10"
-val AkkaManagementVersion = "1.1.4"
-// tag::akka-persistence-cassandra[]
-val AkkaPersistenceCassandraVersion = "1.0.6"
+val PekkoVersion = "1.0.2"
+val PekkoHttpVersion = "1.0.0"
+val PekkoManagementVersion = "1.0.0"
+// tag::pekko-persistence-cassandra[]
+val PekkoPersistenceCassandraVersion = "1.0.0"
-// end::akka-persistence-cassandra[]
-val AlpakkaKafkaVersion = "3.0.1"
-val AkkaProjectionVersion = "1.2.5"
+// end::pekko-persistence-cassandra[]
+val PekkoConnectorsKafkaVersion = "1.0.0"
+val PekkoProjectionVersion = "1.0.0"
-enablePlugins(AkkaGrpcPlugin)
+enablePlugins(PekkoGrpcPlugin)
enablePlugins(JavaAppPackaging, DockerPlugin)
dockerBaseImage := "docker.io/library/adoptopenjdk:11-jre-hotspot"
@@ -40,44 +40,42 @@ dockerUsername := sys.props.get("docker.username")
dockerRepository := sys.props.get("docker.registry")
ThisBuild / dynverSeparator := "-"
-// tag::akka-persistence-cassandra[]
+// tag::pekko-persistence-cassandra[]
libraryDependencies ++= Seq(
- // end::akka-persistence-cassandra[]
+ // end::pekko-persistence-cassandra[]
// 1. Basic dependencies for a clustered application
- "com.typesafe.akka" %% "akka-stream" % AkkaVersion,
- "com.typesafe.akka" %% "akka-cluster-typed" % AkkaVersion,
- "com.typesafe.akka" %% "akka-cluster-sharding-typed" % AkkaVersion,
- "com.typesafe.akka" %% "akka-actor-testkit-typed" % AkkaVersion % Test,
- "com.typesafe.akka" %% "akka-stream-testkit" % AkkaVersion % Test,
- // Akka Management powers Health Checks and Akka Cluster Bootstrapping
- "com.lightbend.akka.management" %% "akka-management" % AkkaManagementVersion,
- "com.typesafe.akka" %% "akka-http" % AkkaHttpVersion,
- "com.typesafe.akka" %% "akka-http-spray-json" % AkkaHttpVersion,
- "com.lightbend.akka.management" %% "akka-management-cluster-http" %
AkkaManagementVersion,
- "com.lightbend.akka.management" %% "akka-management-cluster-bootstrap" %
AkkaManagementVersion,
- "com.lightbend.akka.discovery" %% "akka-discovery-kubernetes-api" %
AkkaManagementVersion,
- "com.typesafe.akka" %% "akka-discovery" % AkkaVersion,
+ "org.apache.pekko" %% "pekko-stream" % PekkoVersion,
+ "org.apache.pekko" %% "pekko-cluster-typed" % PekkoVersion,
+ "org.apache.pekko" %% "pekko-cluster-sharding-typed" % PekkoVersion,
+ "org.apache.pekko" %% "pekko-actor-testkit-typed" % PekkoVersion % Test,
+ "org.apache.pekko" %% "pekko-stream-testkit" % PekkoVersion % Test,
+ // Pekko Management powers Health Checks and Pekko Cluster Bootstrapping
+ "org.apache.pekko" %% "pekko-management" % PekkoManagementVersion,
+ "org.apache.pekko" %% "pekko-http" % PekkoHttpVersion,
+ "org.apache.pekko" %% "pekko-http-spray-json" % PekkoHttpVersion,
+ "org.apache.pekko" %% "pekko-management-cluster-http" %
PekkoManagementVersion,
+ "org.apache.pekko" %% "pekko-management-cluster-bootstrap" %
PekkoManagementVersion,
+ "org.apache.pekko" %% "pekko-discovery-kubernetes-api" %
PekkoManagementVersion,
+ "org.apache.pekko" %% "pekko-discovery" % PekkoVersion,
// Common dependencies for logging and testing
- "com.typesafe.akka" %% "akka-slf4j" % AkkaVersion,
+ "org.apache.pekko" %% "pekko-slf4j" % PekkoVersion,
"ch.qos.logback" % "logback-classic" % "1.2.13",
"org.scalatest" %% "scalatest" % "3.2.17" % Test,
- // 2. Using gRPC and/or protobuf
- "com.typesafe.akka" %% "akka-http2-support" % AkkaHttpVersion,
- // 3. Using Akka Persistence
- "com.typesafe.akka" %% "akka-persistence-typed" % AkkaVersion,
- "com.typesafe.akka" %% "akka-serialization-jackson" % AkkaVersion,
- // tag::akka-persistence-cassandra[]
- "com.typesafe.akka" %% "akka-persistence-cassandra" %
AkkaPersistenceCassandraVersion,
- // end::akka-persistence-cassandra[]
- "com.typesafe.akka" %% "akka-persistence-testkit" % AkkaVersion % Test,
- // 4. Querying or projecting data from Akka Persistence
- "com.typesafe.akka" %% "akka-persistence-query" % AkkaVersion,
- "com.lightbend.akka" %% "akka-projection-eventsourced" %
AkkaProjectionVersion,
- // tag::akka-projection-cassandra[]
- "com.lightbend.akka" %% "akka-projection-cassandra" % AkkaProjectionVersion,
- // end::akka-projection-cassandra[]
- "com.typesafe.akka" %% "akka-stream-kafka" % AlpakkaKafkaVersion,
- "com.lightbend.akka" %% "akka-projection-testkit" % AkkaProjectionVersion %
Test
- // tag::akka-persistence-cassandra[]
+ // 3. Using Pekko Persistence
+ "org.apache.pekko" %% "pekko-persistence-typed" % PekkoVersion,
+ "org.apache.pekko" %% "pekko-serialization-jackson" % PekkoVersion,
+ // tag::pekko-persistence-cassandra[]
+ "org.apache.pekko" %% "pekko-persistence-cassandra" %
PekkoPersistenceCassandraVersion,
+ // end::pekko-persistence-cassandra[]
+ "org.apache.pekko" %% "pekko-persistence-testkit" % PekkoVersion % Test,
+ // 4. Querying or projecting data from Pekko Persistence
+ "org.apache.pekko" %% "pekko-persistence-query" % PekkoVersion,
+ "org.apache.pekko" %% "pekko-projection-eventsourced" %
PekkoProjectionVersion,
+ // tag::pekko-projection-cassandra[]
+ "org.apache.pekko" %% "pekko-projection-cassandra" % PekkoProjectionVersion,
+ // end::pekko-projection-cassandra[]
+ "org.apache.pekko" %% "pekko-connectors-kafka" % PekkoConnectorsKafkaVersion,
+ "org.apache.pekko" %% "pekko-projection-testkit" % PekkoProjectionVersion %
Test
+ // tag::pekko-persistence-cassandra[]
)
-// end::akka-persistence-cassandra[]
+// end::pekko-persistence-cassandra[]
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/project/plugins.sbt
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/project/plugins.sbt
index 0ae06b47..d5e76d77 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/project/plugins.sbt
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/project/plugins.sbt
@@ -1,4 +1,4 @@
-addSbtPlugin("com.lightbend.akka.grpc" % "sbt-akka-grpc" % "2.1.5")
+addSbtPlugin("org.apache.pekko" % "pekko-grpc-sbt-plugin" % "1.0.1")
addSbtPlugin("org.scalameta" % "sbt-scalafmt" % "2.4.2")
-addSbtPlugin("com.typesafe.sbt" % "sbt-native-packager" % "1.8.1")
+addSbtPlugin("com.github.sbt" % "sbt-native-packager" % "1.9.16")
addSbtPlugin("com.dwijnand" % "sbt-dynver" % "4.1.1")
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/application.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/application.conf
index f878dbfd..6877a31c 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/application.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/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-scala/src/main/resources/cluster.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/cluster.conf
index e982dfe1..c75faa0c 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/cluster.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/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-scala/src/main/resources/grpc.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/grpc.conf
index 15b34d62..ad1de437 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/grpc.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/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-scala/src/main/resources/kafka.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/kafka.conf
index ea02c13e..616cb152 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/kafka.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/kafka.conf
@@ -4,14 +4,14 @@ 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-scala/src/main/resources/local-shared.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/local-shared.conf
index 417b63a6..b6628388 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/local-shared.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/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-scala/src/main/resources/local1.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/local1.conf
index 20e3b819..9e9a6f43 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/local1.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/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-scala/src/main/resources/local2.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/local2.conf
index fe3d6a5d..41672bbd 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/local2.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/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-scala/src/main/resources/local3.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/local3.conf
index f33c855f..a54e6d5b 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/local3.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/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-scala/src/main/resources/logback.xml
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/logback.xml
index cc3e40e0..93f2d29a 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/logback.xml
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/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-scala/src/main/resources/persistence.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/persistence.conf
index 4326f94b..18ad39e9 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/persistence.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/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-scala/src/main/resources/serialization.conf
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/serialization.conf
index 7d153b9c..74f6bdcf 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/resources/serialization.conf
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/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-scala/src/main/scala/shopping/cart/CborSerializable.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/CborSerializable.scala
index 785144bd..c86961b6 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/CborSerializable.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/CborSerializable.scala
@@ -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).
+ * Enabled in serialization.conf `pekko.actor.serialization-bindings` (via
application.conf).
*/
trait CborSerializable
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ItemPopularityProjection.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ItemPopularityProjection.scala
index 2a2f6617..eb5a4c68 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ItemPopularityProjection.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ItemPopularityProjection.scala
@@ -1,18 +1,18 @@
// tag::projection[]
package shopping.cart
-import akka.actor.typed.ActorSystem
-import akka.cluster.sharding.typed.ShardedDaemonProcessSettings
-import akka.cluster.sharding.typed.scaladsl.ShardedDaemonProcess
-import akka.persistence.cassandra.query.scaladsl.CassandraReadJournal
-import akka.persistence.query.Offset
-import akka.projection.ProjectionBehavior
-import akka.projection.ProjectionId
-import akka.projection.cassandra.scaladsl.CassandraProjection
-import akka.projection.eventsourced.EventEnvelope
-import akka.projection.eventsourced.scaladsl.EventSourcedProvider
-import akka.projection.scaladsl.AtLeastOnceProjection
-import akka.projection.scaladsl.SourceProvider
+import org.apache.pekko.actor.typed.ActorSystem
+import org.apache.pekko.cluster.sharding.typed.ShardedDaemonProcessSettings
+import org.apache.pekko.cluster.sharding.typed.scaladsl.ShardedDaemonProcess
+import
org.apache.pekko.persistence.cassandra.query.scaladsl.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.scaladsl.CassandraProjection
+import org.apache.pekko.projection.eventsourced.EventEnvelope
+import org.apache.pekko.projection.eventsourced.scaladsl.EventSourcedProvider
+import org.apache.pekko.projection.scaladsl.AtLeastOnceProjection
+import org.apache.pekko.projection.scaladsl.SourceProvider
object ItemPopularityProjection {
// tag::howto-read-side-without-role[]
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ItemPopularityProjectionHandler.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ItemPopularityProjectionHandler.scala
index 88eea82c..8aa44336 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ItemPopularityProjectionHandler.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ItemPopularityProjectionHandler.scala
@@ -4,10 +4,10 @@ package shopping.cart
import scala.concurrent.ExecutionContext
import scala.concurrent.Future
-import akka.Done
-import akka.actor.typed.ActorSystem
-import akka.projection.eventsourced.EventEnvelope
-import akka.projection.scaladsl.Handler
+import org.apache.pekko.Done
+import org.apache.pekko.actor.typed.ActorSystem
+import org.apache.pekko.projection.eventsourced.EventEnvelope
+import org.apache.pekko.projection.scaladsl.Handler
import org.slf4j.LoggerFactory
class ItemPopularityProjectionHandler(
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ItemPopularityRepository.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ItemPopularityRepository.scala
index ad213d2f..2b558edf 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ItemPopularityRepository.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ItemPopularityRepository.scala
@@ -3,10 +3,10 @@
package shopping.cart
import scala.concurrent.Future
-import akka.Done
+import org.apache.pekko.Done
// end::trait[]
import scala.concurrent.ExecutionContext
-import akka.stream.alpakka.cassandra.scaladsl.CassandraSession
+import org.apache.pekko.stream.connectors.cassandra.scaladsl.CassandraSession
// end::impl[]
// tag::trait[]
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/Main.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/Main.scala
index 6e7ba925..1cc0a541 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/Main.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/Main.scala
@@ -1,16 +1,16 @@
package shopping.cart
-import akka.actor.typed.scaladsl.Behaviors
-import akka.actor.typed.ActorSystem
-import akka.management.cluster.bootstrap.ClusterBootstrap
-import akka.management.scaladsl.AkkaManagement
+import org.apache.pekko.actor.typed.scaladsl.Behaviors
+import org.apache.pekko.actor.typed.ActorSystem
+import org.apache.pekko.management.cluster.bootstrap.ClusterBootstrap
+import org.apache.pekko.management.scaladsl.PekkoManagement
import org.slf4j.LoggerFactory
import scala.util.control.NonFatal
import shopping.order.proto.{ ShoppingOrderService, ShoppingOrderServiceClient
}
-import akka.grpc.GrpcClientSettings
+import org.apache.pekko.grpc.GrpcClientSettings
// tag::ItemPopularityProjection[]
-import akka.stream.alpakka.cassandra.scaladsl.CassandraSessionRegistry
+import
org.apache.pekko.stream.connectors.cassandra.scaladsl.CassandraSessionRegistry
// end::ItemPopularityProjection[]
@@ -32,19 +32,19 @@ object Main {
}
def init(system: ActorSystem[_], orderService: ShoppingOrderService): Unit =
{
- AkkaManagement(system).start()
+ PekkoManagement(system).start()
ClusterBootstrap(system).start()
ShoppingCart.init(system)
// tag::ItemPopularityProjection[]
val session = CassandraSessionRegistry(system).sessionFor(
- "akka.persistence.cassandra"
+ "pekko.persistence.cassandra"
) // <1>
// use same keyspace for the item_popularity table as the offset store
val itemPopularityKeyspace =
system.settings.config
- .getString("akka.projection.cassandra.offset-store.keyspace")
+ .getString("pekko.projection.cassandra.offset-store.keyspace")
val itemPopularityRepository =
new ItemPopularityRepositoryImpl(session, itemPopularityKeyspace)(
system.executionContext
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/PublishEventsProjection.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/PublishEventsProjection.scala
index 52289216..512df855 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/PublishEventsProjection.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/PublishEventsProjection.scala
@@ -1,18 +1,21 @@
package shopping.cart
-import akka.actor.CoordinatedShutdown
-import akka.actor.typed.ActorSystem
-import akka.cluster.sharding.typed.ShardedDaemonProcessSettings
-import akka.cluster.sharding.typed.scaladsl.ShardedDaemonProcess
-import akka.kafka.ProducerSettings
-import akka.kafka.scaladsl.SendProducer
-import akka.persistence.cassandra.query.scaladsl.CassandraReadJournal
-import akka.persistence.query.Offset
-import akka.projection.cassandra.scaladsl.CassandraProjection
-import akka.projection.eventsourced.EventEnvelope
-import akka.projection.eventsourced.scaladsl.EventSourcedProvider
-import akka.projection.scaladsl.{ AtLeastOnceProjection, SourceProvider }
-import akka.projection.{ ProjectionBehavior, ProjectionId }
+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.scaladsl.ShardedDaemonProcess
+import org.apache.pekko.kafka.ProducerSettings
+import org.apache.pekko.kafka.scaladsl.SendProducer
+import
org.apache.pekko.persistence.cassandra.query.scaladsl.CassandraReadJournal
+import org.apache.pekko.persistence.query.Offset
+import org.apache.pekko.projection.cassandra.scaladsl.CassandraProjection
+import org.apache.pekko.projection.eventsourced.EventEnvelope
+import org.apache.pekko.projection.eventsourced.scaladsl.EventSourcedProvider
+import org.apache.pekko.projection.scaladsl.{
+ AtLeastOnceProjection,
+ SourceProvider
+}
+import org.apache.pekko.projection.{ ProjectionBehavior, ProjectionId }
import org.apache.kafka.common.serialization.{
ByteArraySerializer,
StringSerializer
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/PublishEventsProjectionHandler.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/PublishEventsProjectionHandler.scala
index a4f294eb..564ae880 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/PublishEventsProjectionHandler.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/PublishEventsProjectionHandler.scala
@@ -4,11 +4,11 @@ package shopping.cart
import scala.concurrent.ExecutionContext
import scala.concurrent.Future
-import akka.Done
-import akka.actor.typed.ActorSystem
-import akka.kafka.scaladsl.SendProducer
-import akka.projection.eventsourced.EventEnvelope
-import akka.projection.scaladsl.Handler
+import org.apache.pekko.Done
+import org.apache.pekko.actor.typed.ActorSystem
+import org.apache.pekko.kafka.scaladsl.SendProducer
+import org.apache.pekko.projection.eventsourced.EventEnvelope
+import org.apache.pekko.projection.scaladsl.Handler
import com.google.protobuf.any.{ Any => ScalaPBAny }
import org.apache.kafka.clients.producer.ProducerRecord
import org.slf4j.LoggerFactory
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/SendOrderProjection.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/SendOrderProjection.scala
index f9eb8d0f..5e3a5ace 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/SendOrderProjection.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/SendOrderProjection.scala
@@ -1,17 +1,17 @@
package shopping.cart
-import akka.actor.typed.ActorSystem
-import akka.cluster.sharding.typed.ShardedDaemonProcessSettings
-import akka.cluster.sharding.typed.scaladsl.ShardedDaemonProcess
-import akka.persistence.cassandra.query.scaladsl.CassandraReadJournal
-import akka.persistence.query.Offset
-import akka.projection.ProjectionBehavior
-import akka.projection.ProjectionId
-import akka.projection.cassandra.scaladsl.CassandraProjection
-import akka.projection.eventsourced.EventEnvelope
-import akka.projection.eventsourced.scaladsl.EventSourcedProvider
-import akka.projection.scaladsl.AtLeastOnceProjection
-import akka.projection.scaladsl.SourceProvider
+import org.apache.pekko.actor.typed.ActorSystem
+import org.apache.pekko.cluster.sharding.typed.ShardedDaemonProcessSettings
+import org.apache.pekko.cluster.sharding.typed.scaladsl.ShardedDaemonProcess
+import
org.apache.pekko.persistence.cassandra.query.scaladsl.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.scaladsl.CassandraProjection
+import org.apache.pekko.projection.eventsourced.EventEnvelope
+import org.apache.pekko.projection.eventsourced.scaladsl.EventSourcedProvider
+import org.apache.pekko.projection.scaladsl.AtLeastOnceProjection
+import org.apache.pekko.projection.scaladsl.SourceProvider
import shopping.order.proto.ShoppingOrderService
object SendOrderProjection {
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/SendOrderProjectionHandler.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/SendOrderProjectionHandler.scala
index fe2816f9..d4f2c46a 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/SendOrderProjectionHandler.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/SendOrderProjectionHandler.scala
@@ -3,12 +3,12 @@ package shopping.cart
import scala.concurrent.ExecutionContext
import scala.concurrent.Future
-import akka.Done
-import akka.actor.typed.ActorSystem
-import akka.cluster.sharding.typed.scaladsl.ClusterSharding
-import akka.projection.eventsourced.EventEnvelope
-import akka.projection.scaladsl.Handler
-import akka.util.Timeout
+import org.apache.pekko.Done
+import org.apache.pekko.actor.typed.ActorSystem
+import org.apache.pekko.cluster.sharding.typed.scaladsl.ClusterSharding
+import org.apache.pekko.projection.eventsourced.EventEnvelope
+import org.apache.pekko.projection.scaladsl.Handler
+import org.apache.pekko.util.Timeout
import org.slf4j.LoggerFactory
import shopping.order.proto.Item
import shopping.order.proto.OrderRequest
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ShoppingCart.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ShoppingCart.scala
index 095d36e2..9993e028 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ShoppingCart.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ShoppingCart.scala
@@ -4,22 +4,22 @@ import java.time.Instant
import scala.concurrent.duration._
-import akka.actor.typed.ActorRef
-import akka.actor.typed.ActorSystem
-import akka.actor.typed.Behavior
-import akka.actor.typed.SupervisorStrategy
-import akka.cluster.sharding.typed.scaladsl.ClusterSharding
-import akka.cluster.sharding.typed.scaladsl.Entity
+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.cluster.sharding.typed.scaladsl.ClusterSharding
+import org.apache.pekko.cluster.sharding.typed.scaladsl.Entity
// tag::importEntityContext[]
-import akka.cluster.sharding.typed.scaladsl.EntityContext
+import org.apache.pekko.cluster.sharding.typed.scaladsl.EntityContext
// end::importEntityContext[]
-import akka.cluster.sharding.typed.scaladsl.EntityTypeKey
-import akka.pattern.StatusReply
-import akka.persistence.typed.PersistenceId
-import akka.persistence.typed.scaladsl.Effect
-import akka.persistence.typed.scaladsl.EventSourcedBehavior
-import akka.persistence.typed.scaladsl.ReplyEffect
-import akka.persistence.typed.scaladsl.RetentionCriteria
+import org.apache.pekko.cluster.sharding.typed.scaladsl.EntityTypeKey
+import org.apache.pekko.pattern.StatusReply
+import org.apache.pekko.persistence.typed.PersistenceId
+import org.apache.pekko.persistence.typed.scaladsl.Effect
+import org.apache.pekko.persistence.typed.scaladsl.EventSourcedBehavior
+import org.apache.pekko.persistence.typed.scaladsl.ReplyEffect
+import org.apache.pekko.persistence.typed.scaladsl.RetentionCriteria
/**
* 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-scala/src/main/scala/shopping/cart/ShoppingCartServer.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ShoppingCartServer.scala
index 5f7648d4..b5471245 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ShoppingCartServer.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ShoppingCartServer.scala
@@ -6,12 +6,12 @@ import scala.concurrent.duration._
import scala.util.Failure
import scala.util.Success
-import akka.actor.typed.ActorSystem
-import akka.grpc.scaladsl.ServerReflection
-import akka.grpc.scaladsl.ServiceHandler
-import akka.http.scaladsl.Http
-import akka.http.scaladsl.model.HttpRequest
-import akka.http.scaladsl.model.HttpResponse
+import org.apache.pekko.actor.typed.ActorSystem
+import org.apache.pekko.grpc.scaladsl.ServerReflection
+import org.apache.pekko.grpc.scaladsl.ServiceHandler
+import org.apache.pekko.http.scaladsl.Http
+import org.apache.pekko.http.scaladsl.model.HttpRequest
+import org.apache.pekko.http.scaladsl.model.HttpResponse
object ShoppingCartServer {
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ShoppingCartServiceImpl.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ShoppingCartServiceImpl.scala
index c22fd85a..4312decc 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ShoppingCartServiceImpl.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/main/scala/shopping/cart/ShoppingCartServiceImpl.scala
@@ -4,16 +4,16 @@ import java.util.concurrent.TimeoutException
import scala.concurrent.Future
-import akka.actor.typed.ActorSystem
-import akka.cluster.sharding.typed.scaladsl.ClusterSharding
-import akka.grpc.GrpcServiceException
-import akka.util.Timeout
+import org.apache.pekko.actor.typed.ActorSystem
+import org.apache.pekko.cluster.sharding.typed.scaladsl.ClusterSharding
+import org.apache.pekko.grpc.GrpcServiceException
+import org.apache.pekko.util.Timeout
import io.grpc.Status
import org.slf4j.LoggerFactory
// tag::moreOperations[]
-import akka.actor.typed.ActorRef
-import akka.pattern.StatusReply
+import org.apache.pekko.actor.typed.ActorRef
+import org.apache.pekko.pattern.StatusReply
// end::moreOperations[]
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/resources/logback-test.xml
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/resources/logback-test.xml
index 053b04b6..b8f58bc8 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/resources/logback-test.xml
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/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>
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/CreateTableTestUtils.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/CreateTableTestUtils.scala
index 290eaaad..f7e8fa15 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/CreateTableTestUtils.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/CreateTableTestUtils.scala
@@ -1,14 +1,14 @@
package shopping.cart
-import akka.actor.typed.ActorSystem
-import akka.stream.alpakka.cassandra.scaladsl.CassandraSessionRegistry
+import org.apache.pekko.actor.typed.ActorSystem
+import
org.apache.pekko.stream.connectors.cassandra.scaladsl.CassandraSessionRegistry
import shopping.cart.ItemPopularityRepositoryImpl.popularityTable
object CreateTableTestUtils {
def createTables(system: ActorSystem[_]): Unit = {
import org.slf4j.LoggerFactory
- import akka.projection.cassandra.scaladsl.CassandraProjection
+ import org.apache.pekko.projection.cassandra.scaladsl.CassandraProjection
import scala.concurrent.Await
import scala.concurrent.duration._
@@ -19,9 +19,9 @@ object CreateTableTestUtils {
// use same keyspace for the item_popularity table as the offset store
val keyspace = system.settings.config
- .getString("akka.projection.cassandra.offset-store.keyspace")
+ .getString("pekko.projection.cassandra.offset-store.keyspace")
val session =
- CassandraSessionRegistry(system).sessionFor("akka.persistence.cassandra")
+
CassandraSessionRegistry(system).sessionFor("pekko.persistence.cassandra")
Await.result(
session.executeDDL(
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/IntegrationSpec.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/IntegrationSpec.scala
index 746dcbe9..eb78e1b6 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/IntegrationSpec.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/IntegrationSpec.scala
@@ -7,17 +7,17 @@ import scala.concurrent.ExecutionContext
import scala.concurrent.Future
import scala.concurrent.duration._
-import akka.actor.CoordinatedShutdown
-import akka.actor.testkit.typed.scaladsl.ActorTestKit
-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.scaladsl.Consumer
-import akka.persistence.testkit.scaladsl.PersistenceInit
-import akka.testkit.SocketUtil
+import org.apache.pekko.actor.CoordinatedShutdown
+import org.apache.pekko.actor.testkit.typed.scaladsl.ActorTestKit
+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.scaladsl.Consumer
+import org.apache.pekko.persistence.testkit.scaladsl.PersistenceInit
+import org.apache.pekko.testkit.SocketUtil
import com.google.protobuf.any.{ Any => ScalaPBAny }
import com.typesafe.config.Config
import com.typesafe.config.ConfigFactory
@@ -41,14 +41,14 @@ object IntegrationSpec {
val config: Config = ConfigFactory
.parseString(s"""
- 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
}
@@ -69,24 +69,24 @@ object IntegrationSpec {
advanced.session-leak.threshold = 10
}
- akka.projection.cassandra.offset-store.keyspace = $keyspace
+ pekko.projection.cassandra.offset-store.keyspace = $keyspace
shopping-cart-service.kafka.topic =
"shopping-cart-events_$uniqueQualifier"
- 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
}
# 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
}
@@ -104,8 +104,8 @@ object IntegrationSpec {
interface = "localhost"
port = $grpcPort
}
- akka.management.http.port = ${managementPorts(managementPortIndex)}
- akka.discovery.config.services {
+ pekko.management.http.port = ${managementPorts(managementPortIndex)}
+ pekko.discovery.config.services {
"shopping-cart-service" {
endpoints = [
{host = "127.0.0.1", port = ${managementPorts(0)}},
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/ItemPopularityIntegrationSpec.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/ItemPopularityIntegrationSpec.scala
index 7553cefa..60aa7078 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/ItemPopularityIntegrationSpec.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/ItemPopularityIntegrationSpec.scala
@@ -4,13 +4,13 @@ import scala.concurrent.Await
import scala.concurrent.Future
import scala.concurrent.duration._
-import akka.actor.testkit.typed.scaladsl.ScalaTestWithActorTestKit
-import akka.cluster.MemberStatus
-import akka.cluster.sharding.typed.scaladsl.ClusterSharding
-import akka.cluster.typed.Cluster
-import akka.cluster.typed.Join
-import akka.persistence.testkit.scaladsl.PersistenceInit
-import akka.stream.alpakka.cassandra.scaladsl.CassandraSessionRegistry
+import org.apache.pekko.actor.testkit.typed.scaladsl.ScalaTestWithActorTestKit
+import org.apache.pekko.cluster.MemberStatus
+import org.apache.pekko.cluster.sharding.typed.scaladsl.ClusterSharding
+import org.apache.pekko.cluster.typed.Cluster
+import org.apache.pekko.cluster.typed.Join
+import org.apache.pekko.persistence.testkit.scaladsl.PersistenceInit
+import
org.apache.pekko.stream.connectors.cassandra.scaladsl.CassandraSessionRegistry
import com.typesafe.config.Config
import com.typesafe.config.ConfigFactory
import org.scalatest.wordspec.AnyWordSpecLike
@@ -22,12 +22,12 @@ object ItemPopularityIntegrationSpec {
val config: Config = ConfigFactory
.parseString(s"""
- 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
}
@@ -48,7 +48,7 @@ object ItemPopularityIntegrationSpec {
basic.load-balancing-policy.local-datacenter = "datacenter1"
}
- akka.projection.cassandra.offset-store.keyspace = $keyspace
+ pekko.projection.cassandra.offset-store.keyspace = $keyspace
""")
.withFallback(ConfigFactory.load())
@@ -60,11 +60,11 @@ class ItemPopularityIntegrationSpec
private lazy val itemPopularityRepository = {
val session =
- CassandraSessionRegistry(system).sessionFor("akka.persistence.cassandra")
+
CassandraSessionRegistry(system).sessionFor("pekko.persistence.cassandra")
// use same keyspace for the item_popularity table as the offset store
val itemPopularityKeyspace =
system.settings.config
- .getString("akka.projection.cassandra.offset-store.keyspace")
+ .getString("pekko.projection.cassandra.offset-store.keyspace")
new ItemPopularityRepositoryImpl(session, itemPopularityKeyspace)(
system.executionContext)
}
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/ItemPopularityProjectionSpec.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/ItemPopularityProjectionSpec.scala
index 203f2e79..5e0e5fbb 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/ItemPopularityProjectionSpec.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/ItemPopularityProjectionSpec.scala
@@ -4,15 +4,15 @@ import java.time.Instant
import scala.concurrent.Future
-import akka.Done
-import akka.actor.testkit.typed.scaladsl.ScalaTestWithActorTestKit
-import akka.persistence.query.Offset
-import akka.projection.ProjectionId
-import akka.projection.eventsourced.EventEnvelope
-import akka.projection.testkit.scaladsl.TestProjection
-import akka.projection.testkit.scaladsl.TestSourceProvider
-import akka.projection.testkit.scaladsl.ProjectionTestKit
-import akka.stream.scaladsl.Source
+import org.apache.pekko.Done
+import org.apache.pekko.actor.testkit.typed.scaladsl.ScalaTestWithActorTestKit
+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.scaladsl.TestProjection
+import org.apache.pekko.projection.testkit.scaladsl.TestSourceProvider
+import org.apache.pekko.projection.testkit.scaladsl.ProjectionTestKit
+import org.apache.pekko.stream.scaladsl.Source
import org.scalatest.wordspec.AnyWordSpecLike
object ItemPopularityProjectionSpec {
@@ -67,7 +67,7 @@ class ItemPopularityProjectionSpec
.CheckedOut("a7098", Instant.parse("2020-01-01T12:00:00.00Z")),
2L),
createEnvelope(
- ShoppingCart.ItemAdded("0d12d", "akka t-shirt", 1),
+ ShoppingCart.ItemAdded("0d12d", "pekko t-shirt", 1),
3L),
createEnvelope(ShoppingCart.ItemAdded("0d12d", "skis", 1), 4L),
createEnvelope(ShoppingCart.ItemRemoved("0d12d", "skis", 1), 5L),
@@ -93,7 +93,7 @@ class ItemPopularityProjectionSpec
projectionTestKit.run(projection) {
repository.counts shouldBe Map(
"bowling shoes" -> 2,
- "akka t-shirt" -> 1,
+ "pekko t-shirt" -> 1,
"skis" -> 0)
}
}
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/ShoppingCartSpec.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/ShoppingCartSpec.scala
index 09246e57..63607efa 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/ShoppingCartSpec.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-cassandra-scala/src/test/scala/shopping/cart/ShoppingCartSpec.scala
@@ -1,8 +1,8 @@
package shopping.cart
-import akka.actor.testkit.typed.scaladsl.ScalaTestWithActorTestKit
-import akka.pattern.StatusReply
-import akka.persistence.testkit.scaladsl.EventSourcedBehaviorTestKit
+import org.apache.pekko.actor.testkit.typed.scaladsl.ScalaTestWithActorTestKit
+import org.apache.pekko.pattern.StatusReply
+import
org.apache.pekko.persistence.testkit.scaladsl.EventSourcedBehaviorTestKit
import com.typesafe.config.ConfigFactory
import org.scalatest.BeforeAndAfterEach
import org.scalatest.wordspec.AnyWordSpecLike
@@ -10,7 +10,7 @@ import org.scalatest.wordspec.AnyWordSpecLike
object ShoppingCartSpec {
val config = ConfigFactory
.parseString("""
- 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-java/pom.xml
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-java/pom.xml
index 93493e1b..7c1bb5ff 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-java/pom.xml
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-java/pom.xml
@@ -17,7 +17,12 @@
<properties>
<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-jdbc.version>1.0.0</pekko-persistence-jdbc.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>
@@ -29,9 +34,9 @@
<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>
@@ -47,60 +52,68 @@
<dependencies>
<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.lightbend.akka</groupId>
-
<artifactId>akka-persistence-jdbc_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-persistence-jdbc_${scala.binary.version}</artifactId>
+ <version>${pekko-persistence-jdbc.version}</version>
</dependency>
<dependency>
- <groupId>com.lightbend.akka</groupId>
-
<artifactId>akka-projection-eventsourced_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-projection-eventsourced_${scala.binary.version}</artifactId>
+ <version>${pekko-projection.version}</version>
</dependency>
<dependency>
- <groupId>com.lightbend.akka</groupId>
-
<artifactId>akka-projection-jdbc_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-projection-jdbc_${scala.binary.version}</artifactId>
+ <version>${pekko-projection.version}</version>
</dependency>
<dependency>
- <groupId>com.typesafe.akka</groupId>
- <artifactId>akka-stream-kafka_${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-http_${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.management</groupId>
-
<artifactId>akka-management-cluster-bootstrap_${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.discovery</groupId>
-
<artifactId>akka-discovery-kubernetes-api_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-discovery-kubernetes-api_${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>
@@ -125,32 +138,34 @@
</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>
- <!-- tag::akka-sbr-kubernetes-lease[] -->
+ <!-- tag::pekko-sbr-kubernetes-lease[] -->
<dependency>
- <groupId>com.lightbend.akka.management</groupId>
-
<artifactId>akka-lease-kubernetes_${scala.binary.version}</artifactId>
+ <groupId>org.apache.pekko</groupId>
+
<artifactId>pekko-lease-kubernetes_${scala.binary.version}</artifactId>
+ <version>${pekko-management.version}</version>
</dependency>
- <!-- end::akka-sbr-kubernetes-lease[] -->
+ <!-- end::pekko-sbr-kubernetes-lease[] -->
<dependency>
<groupId>junit</groupId>
@@ -200,9 +215,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-java/src/main/java/shopping/cart/ItemPopularityProjection.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-java/src/main/java/shopping/cart/ItemPopularityProjection.java
index 1d497301..c97012ac 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-java/src/main/java/shopping/cart/ItemPopularityProjection.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-java/src/main/java/shopping/cart/ItemPopularityProjection.java
@@ -1,13 +1,13 @@
package shopping.cart;
-import akka.actor.typed.ActorSystem;
-import akka.cluster.sharding.typed.ShardedDaemonProcessSettings;
-import akka.cluster.sharding.typed.javadsl.ShardedDaemonProcess;
-import akka.persistence.query.Offset;
-import akka.projection.ProjectionBehavior;
-import akka.projection.eventsourced.EventEnvelope;
-import akka.projection.javadsl.ExactlyOnceProjection;
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.query.Offset;
+import org.apache.pekko.projection.ProjectionBehavior;
+import org.apache.pekko.projection.eventsourced.EventEnvelope;
+import org.apache.pekko.projection.javadsl.ExactlyOnceProjection;
import org.springframework.orm.jpa.JpaTransactionManager;
import shopping.cart.repository.ItemPopularityRepository;
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-java/src/main/java/shopping/cart/Main.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-java/src/main/java/shopping/cart/Main.java
index 87e3179b..d9b54550 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-java/src/main/java/shopping/cart/Main.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-java/src/main/java/shopping/cart/Main.java
@@ -1,8 +1,8 @@
package shopping.cart;
-import akka.actor.typed.ActorSystem;
-import akka.actor.typed.javadsl.Behaviors;
-import akka.management.javadsl.AkkaManagement;
+import org.apache.pekko.actor.typed.ActorSystem;
+import org.apache.pekko.actor.typed.javadsl.Behaviors;
+import org.apache.pekko.management.javadsl.PekkoManagement;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -21,8 +21,8 @@ public class Main {
}
public static void init(ActorSystem<Void> system) {
- // tag::start-akka-management[]
- AkkaManagement.get(system).start();
- // tag::start-akka-management[]
+ // tag::start-pekko-management[]
+ PekkoManagement.get(system).start();
+ // tag::start-pekko-management[]
}
}
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-java/src/main/java/shopping/cart/ShoppingCart.java
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-java/src/main/java/shopping/cart/ShoppingCart.java
index 3eeb8a8c..b636a20a 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-java/src/main/java/shopping/cart/ShoppingCart.java
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-java/src/main/java/shopping/cart/ShoppingCart.java
@@ -1,19 +1,19 @@
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 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.*;
public final class ShoppingCart
extends EventSourcedBehaviorWithEnforcedReplies<
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/build.sbt
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/build.sbt
index a15b5d60..053f1957 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/build.sbt
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/build.sbt
@@ -22,16 +22,16 @@ Test / logBuffered := false
run / fork := false
Global / cancelable := false // ctrl-c
-val AkkaVersion = "2.6.20"
+val PekkoVersion = "1.0.2"
// tag::dependencies-for-healthchecks[]
-val AkkaHttpVersion = "10.2.10"
-val AkkaManagementVersion = "1.1.4"
+val PekkoHttpVersion = "1.0.0"
+val PekkoManagementVersion = "1.0.0"
// end::dependencies-for-healthchecks[]
-val AkkaPersistenceCassandraVersion = "1.0.6"
-val AlpakkaKafkaVersion = "3.0.1"
-val AkkaProjectionVersion = "1.2.5"
+val PekkoPersistenceCassandraVersion = "1.0.0"
+val PekkoConnectorsKafkaVersion = "1.0.0"
+val PekkoProjectionVersion = "1.0.0"
-enablePlugins(AkkaGrpcPlugin)
+enablePlugins(PekkoGrpcPlugin)
enablePlugins(JavaAppPackaging, DockerPlugin)
dockerBaseImage := "docker.io/library/adoptopenjdk:11-jre-hotspot"
@@ -43,44 +43,42 @@ ThisBuild / dynverSeparator := "-"
libraryDependencies ++= Seq(
// end::dependencies-for-healthchecks[]
// 1. Basic dependencies for a clustered application
- "com.typesafe.akka" %% "akka-stream" % AkkaVersion,
- "com.typesafe.akka" %% "akka-cluster-typed" % AkkaVersion,
- "com.typesafe.akka" %% "akka-cluster-sharding-typed" % AkkaVersion,
- "com.typesafe.akka" %% "akka-actor-testkit-typed" % AkkaVersion % Test,
- "com.typesafe.akka" %% "akka-stream-testkit" % AkkaVersion % Test,
- // Akka Management powers Health Checks and Akka Cluster Bootstrapping
+ "org.apache.pekko" %% "pekko-stream" % PekkoVersion,
+ "org.apache.pekko" %% "pekko-cluster-typed" % PekkoVersion,
+ "org.apache.pekko" %% "pekko-cluster-sharding-typed" % PekkoVersion,
+ "org.apache.pekko" %% "pekko-actor-testkit-typed" % PekkoVersion % Test,
+ "org.apache.pekko" %% "pekko-stream-testkit" % PekkoVersion % Test,
+ // Pekko Management powers Health Checks and Pekko Cluster Bootstrapping
// tag::dependencies-for-healthchecks[]
- "com.lightbend.akka.management" %% "akka-management" % AkkaManagementVersion,
+ "org.apache.pekko" %% "pekko-management" % PekkoManagementVersion,
// end::dependencies-for-healthchecks[]
- "com.typesafe.akka" %% "akka-http" % AkkaHttpVersion,
+ "org.apache.pekko" %% "pekko-http" % PekkoHttpVersion,
// tag::dependencies-for-healthchecks[]
- "com.typesafe.akka" %% "akka-http-spray-json" % AkkaHttpVersion,
- "com.lightbend.akka.management" %% "akka-management-cluster-http" %
AkkaManagementVersion,
+ "org.apache.pekko" %% "pekko-http-spray-json" % PekkoHttpVersion,
+ "org.apache.pekko" %% "pekko-management-cluster-http" %
PekkoManagementVersion,
// end::dependencies-for-healthchecks[]
- "com.lightbend.akka.management" %% "akka-management-cluster-bootstrap" %
AkkaManagementVersion,
- "com.lightbend.akka.discovery" %% "akka-discovery-kubernetes-api" %
AkkaManagementVersion,
- "com.typesafe.akka" %% "akka-discovery" % AkkaVersion,
+ "org.apache.pekko" %% "pekko-management-cluster-bootstrap" %
PekkoManagementVersion,
+ "org.apache.pekko" %% "pekko-discovery-kubernetes-api" %
PekkoManagementVersion,
+ "org.apache.pekko" %% "pekko-discovery" % PekkoVersion,
// Common dependencies for logging and testing
- "com.typesafe.akka" %% "akka-slf4j" % AkkaVersion,
+ "org.apache.pekko" %% "pekko-slf4j" % PekkoVersion,
"ch.qos.logback" % "logback-classic" % "1.2.13",
"org.scalatest" %% "scalatest" % "3.2.17" % Test,
- // 2. Using gRPC and/or protobuf
- "com.typesafe.akka" %% "akka-http2-support" % AkkaHttpVersion,
- // 3. Using Akka Persistence
- "com.typesafe.akka" %% "akka-persistence-typed" % AkkaVersion,
- "com.typesafe.akka" %% "akka-serialization-jackson" % AkkaVersion,
- "com.typesafe.akka" %% "akka-persistence-cassandra" %
AkkaPersistenceCassandraVersion,
- "com.typesafe.akka" %% "akka-persistence-testkit" % AkkaVersion % Test,
- // 4. Querying or projecting data from Akka Persistence
- "com.typesafe.akka" %% "akka-persistence-query" % AkkaVersion,
- "com.lightbend.akka" %% "akka-projection-eventsourced" %
AkkaProjectionVersion,
- "com.lightbend.akka" %% "akka-projection-cassandra" % AkkaProjectionVersion,
- "com.typesafe.akka" %% "akka-stream-kafka" % AlpakkaKafkaVersion,
- "com.lightbend.akka" %% "akka-projection-testkit" % AkkaProjectionVersion %
Test,
+ // 3. Using Pekko Persistence
+ "org.apache.pekko" %% "pekko-persistence-typed" % PekkoVersion,
+ "org.apache.pekko" %% "pekko-serialization-jackson" % PekkoVersion,
+ "org.apache.pekko" %% "pekko-persistence-cassandra" %
PekkoPersistenceCassandraVersion,
+ "org.apache.pekko" %% "pekko-persistence-testkit" % PekkoVersion % Test,
+ // 4. Querying or projecting data from Pekko Persistence
+ "org.apache.pekko" %% "pekko-persistence-query" % PekkoVersion,
+ "org.apache.pekko" %% "pekko-projection-eventsourced" %
PekkoProjectionVersion,
+ "org.apache.pekko" %% "pekko-projection-cassandra" % PekkoProjectionVersion,
+ "org.apache.pekko" %% "pekko-connectors-kafka" % PekkoConnectorsKafkaVersion,
+ "org.apache.pekko" %% "pekko-projection-testkit" % PekkoProjectionVersion %
Test,
// 5. Kubernetes Lease (used by SBR)
- // tag::akka-sbr-kubernetes-lease[]
- "com.lightbend.akka.management" %% "akka-lease-kubernetes" %
AkkaManagementVersion
- // end::akka-sbr-kubernetes-lease[]
+ // tag::pekko-sbr-kubernetes-lease[]
+ "org.apache.pekko" %% "pekko-lease-kubernetes" % PekkoManagementVersion
+ // end::pekko-sbr-kubernetes-lease[]
// tag::dependencies-for-healthchecks[]
)
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/project/plugins.sbt
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/project/plugins.sbt
index 0ae06b47..d5e76d77 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/project/plugins.sbt
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/project/plugins.sbt
@@ -1,4 +1,4 @@
-addSbtPlugin("com.lightbend.akka.grpc" % "sbt-akka-grpc" % "2.1.5")
+addSbtPlugin("org.apache.pekko" % "pekko-grpc-sbt-plugin" % "1.0.1")
addSbtPlugin("org.scalameta" % "sbt-scalafmt" % "2.4.2")
-addSbtPlugin("com.typesafe.sbt" % "sbt-native-packager" % "1.8.1")
+addSbtPlugin("com.github.sbt" % "sbt-native-packager" % "1.9.16")
addSbtPlugin("com.dwijnand" % "sbt-dynver" % "4.1.1")
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/src/main/scala/shopping/cart/ItemPopularityProjection.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/src/main/scala/shopping/cart/ItemPopularityProjection.scala
index 48d5c8ab..2496f3b7 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/src/main/scala/shopping/cart/ItemPopularityProjection.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/src/main/scala/shopping/cart/ItemPopularityProjection.scala
@@ -1,12 +1,12 @@
package shopping.cart
-import akka.actor.typed.ActorSystem
-import akka.cluster.sharding.typed.ShardedDaemonProcessSettings
-import akka.cluster.sharding.typed.scaladsl.ShardedDaemonProcess
-import akka.persistence.query.Offset
-import akka.projection.ProjectionBehavior
-import akka.projection.eventsourced.EventEnvelope
-import akka.projection.scaladsl.AtLeastOnceProjection
+import org.apache.pekko.actor.typed.ActorSystem
+import org.apache.pekko.cluster.sharding.typed.ShardedDaemonProcessSettings
+import org.apache.pekko.cluster.sharding.typed.scaladsl.ShardedDaemonProcess
+import org.apache.pekko.persistence.query.Offset
+import org.apache.pekko.projection.ProjectionBehavior
+import org.apache.pekko.projection.eventsourced.EventEnvelope
+import org.apache.pekko.projection.scaladsl.AtLeastOnceProjection
object ItemPopularityProjection {
// tag::read-side-with-role[]
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/src/main/scala/shopping/cart/ItemPopularityRepository.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/src/main/scala/shopping/cart/ItemPopularityRepository.scala
index 263b39b2..7bf31927 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/src/main/scala/shopping/cart/ItemPopularityRepository.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/src/main/scala/shopping/cart/ItemPopularityRepository.scala
@@ -2,7 +2,7 @@ package shopping.cart
import scala.concurrent.Future
-import akka.Done
+import org.apache.pekko.Done
trait ItemPopularityRepository {
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/src/main/scala/shopping/cart/Main.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/src/main/scala/shopping/cart/Main.scala
index 61f450fb..70f359ad 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/src/main/scala/shopping/cart/Main.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/src/main/scala/shopping/cart/Main.scala
@@ -1,8 +1,8 @@
package shopping.cart
-import akka.actor.typed.scaladsl.Behaviors
-import akka.actor.typed.ActorSystem
-import akka.management.scaladsl.AkkaManagement
+import org.apache.pekko.actor.typed.scaladsl.Behaviors
+import org.apache.pekko.actor.typed.ActorSystem
+import org.apache.pekko.management.scaladsl.PekkoManagement
import org.slf4j.LoggerFactory
import scala.util.control.NonFatal
@@ -22,9 +22,9 @@ object Main {
}
def init(system: ActorSystem[_]): Unit = {
- // tag::start-akka-management[]
- AkkaManagement(system).start()
- // end::start-akka-management[]
+ // tag::start-pekko-management[]
+ PekkoManagement(system).start()
+ // end::start-pekko-management[]
}
}
diff --git
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/src/main/scala/shopping/cart/ShoppingCart.scala
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/src/main/scala/shopping/cart/ShoppingCart.scala
index 8a750b35..e3404141 100644
---
a/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/src/main/scala/shopping/cart/ShoppingCart.scala
+++
b/docs-source/docs/modules/how-to/examples/shopping-cart-service-scala/src/main/scala/shopping/cart/ShoppingCart.scala
@@ -2,13 +2,12 @@ package shopping.cart
import java.time.Instant
-import akka.actor.typed.ActorSystem
-import akka.actor.typed.Behavior
-import akka.cluster.sharding.typed.ShardingEnvelope
-import akka.cluster.sharding.typed.scaladsl.ClusterSharding
-import akka.cluster.sharding.typed.scaladsl.Entity
-import akka.cluster.sharding.typed.scaladsl.EntityContext
-import akka.cluster.sharding.typed.scaladsl.EntityTypeKey
+import org.apache.pekko.actor.typed.ActorSystem
+import org.apache.pekko.actor.typed.Behavior
+import org.apache.pekko.cluster.sharding.typed.scaladsl.ClusterSharding
+import org.apache.pekko.cluster.sharding.typed.scaladsl.Entity
+import org.apache.pekko.cluster.sharding.typed.scaladsl.EntityContext
+import org.apache.pekko.cluster.sharding.typed.scaladsl.EntityTypeKey
object ShoppingCart {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
