Replace akka with pekko

pbernet · Feb 8, 2024 · aad6911 · aad6911
1 parent 64ee0b4
commit aad6911
Show file tree

Hide file tree

Showing 6 changed files with 8 additions and 8 deletions.
diff --git a/src/main/java/util/ConnectionStatusChecker.java b/src/main/java/util/ConnectionStatusChecker.java
@@ -18,7 +18,7 @@
  * Inspired by:
  * https://mindchasers.com/dev/ping
  * <p>
- * No akka-streams here
+ * No pekko-streams here
  */
 public class ConnectionStatusChecker {
     private static final Logger LOGGER = LoggerFactory.getLogger(ConnectionStatusChecker.class);

diff --git a/src/main/scala/akkahttp/SampleRoutes.scala b/src/main/scala/akkahttp/SampleRoutes.scala
@@ -65,7 +65,7 @@ object SampleRoutes extends App with DefaultJsonProtocol with SprayJsonSupport {
   }
 
   val parseFormData: Route =
-  // Set loglevel to "DEBUG" in application.conf for verbose akka-http log output
+    // Set loglevel to "DEBUG" in application.conf for verbose pekko-http log output
     logRequest("log post request") {
       post {
         path("post") {

diff --git a/src/main/scala/akkahttp/oidc/OIDCKeycloak.scala b/src/main/scala/akkahttp/oidc/OIDCKeycloak.scala
@@ -32,7 +32,7 @@ import scala.sys.process.{Process, stringSeqToProcess}
 import scala.util.{Failure, Success}
 
 /**
-  * A "one-click" Keycloak OIDC server with akka-http frontend
+  * A "one-click" Keycloak OIDC server with pekko-http frontend
   *
   * Inspired by:
   * https://scalac.io/blog/user-authentication-keycloak-1

diff --git a/src/main/scala/alpakka/influxdb/InfluxdbReader.scala b/src/main/scala/alpakka/influxdb/InfluxdbReader.scala
@@ -18,7 +18,7 @@ import scala.util.control.NonFatal;
 
 /**
   *
-  * Doc read data via akka-streams via Scala client:
+  * Doc read data via pekko-streams via Scala client:
   * https://github.com/influxdata/influxdb-client-java/tree/master/client-scala
   *
   * Doc Flux query lang:

diff --git a/src/main/scala/interop/ReactiveStreamsInterop.scala b/src/main/scala/interop/ReactiveStreamsInterop.scala
@@ -21,7 +21,7 @@ import scala.concurrent.duration.DurationInt
   * to distribute messages to different consumers:
   *  - Reactor
   *  - RxJava
-  *  - akka-streams
+  *  - pekko-streams
   *
   * Doc:
   * https://doc.akka.io/docs/akka/current/stream/reactive-streams-interop.html
@@ -57,11 +57,11 @@ object ReactiveStreamsInterop extends App {
     .doOnNext(each => logger.info(s"Consumed with RxJava: $each"))
     .subscribe()
 
-  // Slow consumer with akka-streams
+  // Slow consumer with pekko-streams
   Source.fromPublisher(publisher)
     .throttle(2, 2.seconds, 2, ThrottleMode.shaping)
     .map(each => each.toUpperCase())
-    .wireTap(each => logger.info(s"Consumed with akka-streams: $each"))
+    .wireTap(each => logger.info(s"Consumed with pekko-streams: $each"))
     .runWith(Sink.ignore)
 
   // Sender endpoint with Camel

diff --git a/src/main/scala/sample/stream/TransformCSV.scala b/src/main/scala/sample/stream/TransformCSV.scala
@@ -13,7 +13,7 @@ import scala.sys.process._
   * Inspired by:
   * https://discuss.lightbend.com/t/transform-a-csv-file-into-multiple-csv-files-using-akka-stream/3142
   *
-  * Instead of akka-streams we use linux tools (sort/split) for each step to apply the
+  * Instead of pekko-streams we use linux tools (sort/split) for each step to apply the
   * "chainsaw style" transformations to the large csv file.
   * With the additional count this does the same as: [[FlightDelayStreaming]].
   * However the performance is not as good as in FlightDelayStreaming.