This is an automated email from the ASF dual-hosted git repository. fanningpj pushed a commit to branch sqs in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors-samples.git
commit a895afed4136e9d3347b40155de63a358f0c9124 Author: PJ Fanning <[email protected]> AuthorDate: Sat Dec 16 22:24:15 2023 +0100 migrate sqs sample --- .../docs/src/main/paradox/index.md | 4 +-- pekko-connectors-sample-ftp-to-file/README.md | 2 +- .../docs/src/main/paradox/index.md | 4 +-- .../project/Dependencies.scala | 2 +- .../README.md | 2 +- .../docs/src/main/paradox/index.md | 4 +-- .../project/Dependencies.scala | 2 +- pekko-connectors-sample-jms/README.md | 2 +- .../README.md | 2 +- .../docs/src/main/paradox/index.md | 4 +-- .../README.md | 2 +- .../docs/src/main/paradox/index.md | 4 +-- .../project/Dependencies.scala | 2 +- .../README.md | 2 +- .../build.sbt | 2 +- pekko-connectors-sample-mqtt-to-kafka/README.md | 2 +- .../docs/src/main/paradox/index.md | 4 +-- .../project/Dependencies.scala | 2 +- .../README.md | 2 +- .../docs/src/main/paradox/index.md | 4 +-- .../project/Dependencies.scala | 2 +- pekko-connectors-sample-sqs-java/README.md | 2 +- pekko-connectors-sample-sqs-java/build.sbt | 24 +++++++++------- .../sample => samples}/sqssample/EnrichActor.java | 16 +++++------ .../sqssample/EnrichedMessage.java | 2 +- .../sample => samples}/sqssample/Main.java | 32 +++++++++++----------- .../sqssample/MessageFromSqs.java | 2 +- .../sample => samples}/sqssample/PublishToSqs.java | 26 +++++++++--------- .../src/main/resources/application.conf | 6 ++-- .../src/main/resources/logback.xml | 2 +- 30 files changed, 86 insertions(+), 82 deletions(-) diff --git a/pekko-connectors-sample-file-to-elasticsearch/docs/src/main/paradox/index.md b/pekko-connectors-sample-file-to-elasticsearch/docs/src/main/paradox/index.md index 01737fa..195a48d 100644 --- a/pekko-connectors-sample-file-to-elasticsearch/docs/src/main/paradox/index.md +++ b/pekko-connectors-sample-file-to-elasticsearch/docs/src/main/paradox/index.md @@ -90,9 +90,9 @@ Java Scala : @@snip [snip](/src/main/scala/samples/scaladsl/Main.scala) { #running-the-app } -## All Alpakka samples +## All Apache Pekko Connectors samples -Show [Alpakka samples listing](../index.html). +Show [Apache Pekko Connectors samples listing](../index.html). @@toc diff --git a/pekko-connectors-sample-ftp-to-file/README.md b/pekko-connectors-sample-ftp-to-file/README.md index eabe2c5..4da3e55 100644 --- a/pekko-connectors-sample-ftp-to-file/README.md +++ b/pekko-connectors-sample-ftp-to-file/README.md @@ -1,4 +1,4 @@ -# Alpakka sample +# Apache Pekko Connectors sample ## Download all files an FTP server to local files diff --git a/pekko-connectors-sample-ftp-to-file/docs/src/main/paradox/index.md b/pekko-connectors-sample-ftp-to-file/docs/src/main/paradox/index.md index 1f4836b..78efeee 100644 --- a/pekko-connectors-sample-ftp-to-file/docs/src/main/paradox/index.md +++ b/pekko-connectors-sample-ftp-to-file/docs/src/main/paradox/index.md @@ -29,9 +29,9 @@ Java Scala : @@snip [snip](/src/main/scala/samples/scaladsl/Main.scala) { #sample } -### All Alpakka samples +### All Apache Pekko Connectors samples -Show [Alpakka samples listing](../index.html). +Show [Apache Pekko Connectors samples listing](../index.html). @@toc diff --git a/pekko-connectors-sample-ftp-to-file/project/Dependencies.scala b/pekko-connectors-sample-ftp-to-file/project/Dependencies.scala index 373612e..7e564da 100644 --- a/pekko-connectors-sample-ftp-to-file/project/Dependencies.scala +++ b/pekko-connectors-sample-ftp-to-file/project/Dependencies.scala @@ -1,7 +1,7 @@ import sbt._ object Dependencies { - val scalaVer = "2.13.7" + val scalaVer = "2.13.12" // #deps val AkkaVersion = "2.6.19" val AlpakkaVersion = "4.0.0" diff --git a/pekko-connectors-sample-http-csv-to-kafka/README.md b/pekko-connectors-sample-http-csv-to-kafka/README.md index 013ccb4..218db37 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/README.md +++ b/pekko-connectors-sample-http-csv-to-kafka/README.md @@ -1,4 +1,4 @@ -# Alpakka sample +# Apache Pekko Connectors sample ## Fetch CSV via Akka HTTP and publish the data as JSON to Kafka diff --git a/pekko-connectors-sample-http-csv-to-kafka/docs/src/main/paradox/index.md b/pekko-connectors-sample-http-csv-to-kafka/docs/src/main/paradox/index.md index e074950..a8e8ed6 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/docs/src/main/paradox/index.md +++ b/pekko-connectors-sample-http-csv-to-kafka/docs/src/main/paradox/index.md @@ -5,9 +5,9 @@ Dependencies : @@snip [snip](/project/Dependencies.scala) { #dependencies } -### All Alpakka samples +### All Apache Pekko Connectors samples -Show [Alpakka samples listing](../index.html). +Show [Apache Pekko Connectors samples listing](../index.html). @@toc diff --git a/pekko-connectors-sample-http-csv-to-kafka/project/Dependencies.scala b/pekko-connectors-sample-http-csv-to-kafka/project/Dependencies.scala index 95ad919..66be97a 100644 --- a/pekko-connectors-sample-http-csv-to-kafka/project/Dependencies.scala +++ b/pekko-connectors-sample-http-csv-to-kafka/project/Dependencies.scala @@ -1,7 +1,7 @@ import sbt._ object Dependencies { - val scalaVer = "2.13.7" + val scalaVer = "2.13.12" // #dependencies val ScalaTestVersion = "3.1.4" val AkkaVersion = "2.6.19" diff --git a/pekko-connectors-sample-jms/README.md b/pekko-connectors-sample-jms/README.md index fb07b16..e84ee9b 100644 --- a/pekko-connectors-sample-jms/README.md +++ b/pekko-connectors-sample-jms/README.md @@ -1,4 +1,4 @@ -# Apeche Pekko Connectors sample +# Apache Pekko Connectors sample ## Receive JMS messages diff --git a/pekko-connectors-sample-kafka-to-elasticsearch/README.md b/pekko-connectors-sample-kafka-to-elasticsearch/README.md index dce8751..2ad3575 100644 --- a/pekko-connectors-sample-kafka-to-elasticsearch/README.md +++ b/pekko-connectors-sample-kafka-to-elasticsearch/README.md @@ -1,4 +1,4 @@ -# Alpakka sample +# Apache Pekko Connectors sample ## Read from a Kafka topic and publish to Elasticsearch diff --git a/pekko-connectors-sample-kafka-to-elasticsearch/docs/src/main/paradox/index.md b/pekko-connectors-sample-kafka-to-elasticsearch/docs/src/main/paradox/index.md index a513e1a..15403b2 100644 --- a/pekko-connectors-sample-kafka-to-elasticsearch/docs/src/main/paradox/index.md +++ b/pekko-connectors-sample-kafka-to-elasticsearch/docs/src/main/paradox/index.md @@ -5,9 +5,9 @@ Dependencies (sbt notation) : @@snip [snip](/project/Dependencies.scala) { #deps } -### All Alpakka samples +### All Apache Pekko Connectors samples -Show [Alpakka samples listing](../index.html). +Show [Apache Pekko Connectors samples listing](../index.html). @@toc diff --git a/pekko-connectors-sample-kafka-to-websocket-clients/README.md b/pekko-connectors-sample-kafka-to-websocket-clients/README.md index 472830f..b3dd89c 100644 --- a/pekko-connectors-sample-kafka-to-websocket-clients/README.md +++ b/pekko-connectors-sample-kafka-to-websocket-clients/README.md @@ -1,4 +1,4 @@ -# Alpakka sample +# Apache Pekko Connectors sample ## Read from a Kafka topic and push the data to connected websocket clients diff --git a/pekko-connectors-sample-kafka-to-websocket-clients/docs/src/main/paradox/index.md b/pekko-connectors-sample-kafka-to-websocket-clients/docs/src/main/paradox/index.md index b8e3b05..15fa4a2 100644 --- a/pekko-connectors-sample-kafka-to-websocket-clients/docs/src/main/paradox/index.md +++ b/pekko-connectors-sample-kafka-to-websocket-clients/docs/src/main/paradox/index.md @@ -5,9 +5,9 @@ Dependencies (sbt notation) : @@snip [snip](/project/Dependencies.scala) { #deps } -### All Alpakka samples +### All Apache Pekko Connectors samples -Show [Alpakka samples listing](../index.html). +Show [Apache Pekko Connectors samples listing](../index.html). @@toc diff --git a/pekko-connectors-sample-kafka-to-websocket-clients/project/Dependencies.scala b/pekko-connectors-sample-kafka-to-websocket-clients/project/Dependencies.scala index c924c21..8fd58f4 100644 --- a/pekko-connectors-sample-kafka-to-websocket-clients/project/Dependencies.scala +++ b/pekko-connectors-sample-kafka-to-websocket-clients/project/Dependencies.scala @@ -1,7 +1,7 @@ import sbt._ object Dependencies { - val scalaVer = "2.13.7" + val scalaVer = "2.13.12" // #deps val AkkaVersion = "2.6.19" val AkkaHttpVersion = "10.1.12" diff --git a/pekko-connectors-sample-mqtt-http-to-s3-java/README.md b/pekko-connectors-sample-mqtt-http-to-s3-java/README.md index 6a03c5d..de253c3 100644 --- a/pekko-connectors-sample-mqtt-http-to-s3-java/README.md +++ b/pekko-connectors-sample-mqtt-http-to-s3-java/README.md @@ -1,4 +1,4 @@ -# Alpakka sample +# Apache Pekko Connectors sample ### Listen to a MQTT topic, download from URL passed in received message, and upload data from that address to AWS S3 diff --git a/pekko-connectors-sample-mqtt-http-to-s3-java/build.sbt b/pekko-connectors-sample-mqtt-http-to-s3-java/build.sbt index 7071a06..04d83dc 100644 --- a/pekko-connectors-sample-mqtt-http-to-s3-java/build.sbt +++ b/pekko-connectors-sample-mqtt-http-to-s3-java/build.sbt @@ -1,7 +1,7 @@ organization := "com.lightbend.akka.samples" name := "pekko-connectors-samples-mqtt-http-to-s3-java" -ThisBuild / scalaVersion := "2.13.7" +ThisBuild / scalaVersion := "2.13.12" val AkkaVersion = "2.6.19" val AkkaHttpVersion = "10.1.12" diff --git a/pekko-connectors-sample-mqtt-to-kafka/README.md b/pekko-connectors-sample-mqtt-to-kafka/README.md index 6859ffc..615f311 100644 --- a/pekko-connectors-sample-mqtt-to-kafka/README.md +++ b/pekko-connectors-sample-mqtt-to-kafka/README.md @@ -1,4 +1,4 @@ -# Alpakka sample +# Apache Pekko Connectors sample ## Read from an MQTT topic, group messages and publish to Kafka diff --git a/pekko-connectors-sample-mqtt-to-kafka/docs/src/main/paradox/index.md b/pekko-connectors-sample-mqtt-to-kafka/docs/src/main/paradox/index.md index b8e3b05..15fa4a2 100644 --- a/pekko-connectors-sample-mqtt-to-kafka/docs/src/main/paradox/index.md +++ b/pekko-connectors-sample-mqtt-to-kafka/docs/src/main/paradox/index.md @@ -5,9 +5,9 @@ Dependencies (sbt notation) : @@snip [snip](/project/Dependencies.scala) { #deps } -### All Alpakka samples +### All Apache Pekko Connectors samples -Show [Alpakka samples listing](../index.html). +Show [Apache Pekko Connectors samples listing](../index.html). @@toc diff --git a/pekko-connectors-sample-mqtt-to-kafka/project/Dependencies.scala b/pekko-connectors-sample-mqtt-to-kafka/project/Dependencies.scala index d19dba0..9e2fbb4 100644 --- a/pekko-connectors-sample-mqtt-to-kafka/project/Dependencies.scala +++ b/pekko-connectors-sample-mqtt-to-kafka/project/Dependencies.scala @@ -1,7 +1,7 @@ import sbt._ object Dependencies { - val scalaVer = "2.13.7" + val scalaVer = "2.13.12" // #deps val AkkaVersion = "2.6.19" val AlpakkaVersion = "4.0.0" diff --git a/pekko-connectors-sample-rotate-logs-to-ftp/README.md b/pekko-connectors-sample-rotate-logs-to-ftp/README.md index 859d3da..f2a9a05 100644 --- a/pekko-connectors-sample-rotate-logs-to-ftp/README.md +++ b/pekko-connectors-sample-rotate-logs-to-ftp/README.md @@ -1,4 +1,4 @@ -# Alpakka sample +# Apache Pekko Connectors sample ## Rotate data stream over to multiple compressed files on SFTP server diff --git a/pekko-connectors-sample-rotate-logs-to-ftp/docs/src/main/paradox/index.md b/pekko-connectors-sample-rotate-logs-to-ftp/docs/src/main/paradox/index.md index cd71bfd..64ea293 100644 --- a/pekko-connectors-sample-rotate-logs-to-ftp/docs/src/main/paradox/index.md +++ b/pekko-connectors-sample-rotate-logs-to-ftp/docs/src/main/paradox/index.md @@ -26,9 +26,9 @@ Java : @@snip [snip](/src/main/java/samples/javadsl/Main.java) { #sample } -### All Alpakka samples +### All Apache Pekko Connectors samples -Show [Alpakka samples listing](../index.html). +Show [Apache Pekko Connectors samples listing](../index.html). @@toc diff --git a/pekko-connectors-sample-rotate-logs-to-ftp/project/Dependencies.scala b/pekko-connectors-sample-rotate-logs-to-ftp/project/Dependencies.scala index b735a67..cc4a53d 100644 --- a/pekko-connectors-sample-rotate-logs-to-ftp/project/Dependencies.scala +++ b/pekko-connectors-sample-rotate-logs-to-ftp/project/Dependencies.scala @@ -1,7 +1,7 @@ import sbt._ object Dependencies { - val scalaVer = "2.13.7" + val scalaVer = "2.13.12" // #deps val AkkaVersion = "2.6.19" val AlpakkaVersion = "4.0.0" diff --git a/pekko-connectors-sample-sqs-java/README.md b/pekko-connectors-sample-sqs-java/README.md index df07070..0dab496 100644 --- a/pekko-connectors-sample-sqs-java/README.md +++ b/pekko-connectors-sample-sqs-java/README.md @@ -1,4 +1,4 @@ -# Alpakka sample +# Pekko Connectors sample ### Listen to an Amazon SQS topic, enrich the message via calling an actor, publish a new message to SQS and acknowledge/delete the original message diff --git a/pekko-connectors-sample-sqs-java/build.sbt b/pekko-connectors-sample-sqs-java/build.sbt index 6c4cccc..a6762de 100644 --- a/pekko-connectors-sample-sqs-java/build.sbt +++ b/pekko-connectors-sample-sqs-java/build.sbt @@ -1,18 +1,22 @@ -organization := "com.lightbend.alpakka.samples" +organization := "org.apache.pekko" name := "pekko-connectors-samples-sqs-java" -ThisBuild / scalaVersion := "2.13.7" +ThisBuild / scalaVersion := "2.13.12" -val AkkaVersion = "2.6.14" -val AlpakkaVersion = "3.0.4" -val jacksonVersion = "2.11.4" +val PekkoVersion = "1.0.2" +val PekkoConnectorsVersion = "1.0.1" +val jacksonVersion = "2.14.3" libraryDependencies ++= Seq( - "com.typesafe.akka" %% "akka-slf4j" % AkkaVersion, - "com.typesafe.akka" %% "akka-stream" % AkkaVersion, - "com.typesafe.akka" %% "akka-actor-typed" % AkkaVersion, - "com.typesafe.akka" %% "akka-actor" % AkkaVersion, - "com.lightbend.akka" %% "akka-stream-alpakka-sqs" % AlpakkaVersion, + "org.apache.pekko" %% "pekko-slf4j" % PekkoVersion, + "org.apache.pekko" %% "pekko-stream" % PekkoVersion, + "org.apache.pekko" %% "pekko-actor-typed" % PekkoVersion, + "org.apache.pekko" %% "pekko-actor" % PekkoVersion, + "org.apache.pekko" %% "pekko-connectors-sqs" % PekkoConnectorsVersion, + "com.github.pjfanning" %% "aws-spi-pekko-http" % "0.1.0", + "com.fasterxml.jackson.core" % "jackson-annotations" % jacksonVersion, + "com.fasterxml.jackson.core" % "jackson-core" % jacksonVersion, + "com.fasterxml.jackson.core" % "jackson-databind" % jacksonVersion, "ch.qos.logback" % "logback-classic" % "1.2.13", ) diff --git a/pekko-connectors-sample-sqs-java/src/main/java/alpakka/sample/sqssample/EnrichActor.java b/pekko-connectors-sample-sqs-java/src/main/java/samples/sqssample/EnrichActor.java similarity index 74% rename from pekko-connectors-sample-sqs-java/src/main/java/alpakka/sample/sqssample/EnrichActor.java rename to pekko-connectors-sample-sqs-java/src/main/java/samples/sqssample/EnrichActor.java index 91a98aa..6e01ee1 100644 --- a/pekko-connectors-sample-sqs-java/src/main/java/alpakka/sample/sqssample/EnrichActor.java +++ b/pekko-connectors-sample-sqs-java/src/main/java/samples/sqssample/EnrichActor.java @@ -1,11 +1,11 @@ -package alpakka.sample.sqssample; - -import akka.actor.typed.ActorRef; -import akka.actor.typed.Behavior; -import akka.actor.typed.javadsl.AbstractBehavior; -import akka.actor.typed.javadsl.ActorContext; -import akka.actor.typed.javadsl.Behaviors; -import akka.actor.typed.javadsl.Receive; +package samples.sqssample; + +import org.apache.pekko.actor.typed.ActorRef; +import org.apache.pekko.actor.typed.Behavior; +import org.apache.pekko.actor.typed.javadsl.AbstractBehavior; +import org.apache.pekko.actor.typed.javadsl.ActorContext; +import org.apache.pekko.actor.typed.javadsl.Behaviors; +import org.apache.pekko.actor.typed.javadsl.Receive; final class EnrichActor extends AbstractBehavior<EnrichActor.Enrich> { diff --git a/pekko-connectors-sample-sqs-java/src/main/java/alpakka/sample/sqssample/EnrichedMessage.java b/pekko-connectors-sample-sqs-java/src/main/java/samples/sqssample/EnrichedMessage.java similarity index 95% rename from pekko-connectors-sample-sqs-java/src/main/java/alpakka/sample/sqssample/EnrichedMessage.java rename to pekko-connectors-sample-sqs-java/src/main/java/samples/sqssample/EnrichedMessage.java index 9933b0c..d022474 100644 --- a/pekko-connectors-sample-sqs-java/src/main/java/alpakka/sample/sqssample/EnrichedMessage.java +++ b/pekko-connectors-sample-sqs-java/src/main/java/samples/sqssample/EnrichedMessage.java @@ -1,4 +1,4 @@ -package alpakka.sample.sqssample; +package samples.sqssample; import com.fasterxml.jackson.annotation.JsonCreator; import com.fasterxml.jackson.annotation.JsonProperty; diff --git a/pekko-connectors-sample-sqs-java/src/main/java/alpakka/sample/sqssample/Main.java b/pekko-connectors-sample-sqs-java/src/main/java/samples/sqssample/Main.java similarity index 84% rename from pekko-connectors-sample-sqs-java/src/main/java/alpakka/sample/sqssample/Main.java rename to pekko-connectors-sample-sqs-java/src/main/java/samples/sqssample/Main.java index 618085e..13f1e1a 100644 --- a/pekko-connectors-sample-sqs-java/src/main/java/alpakka/sample/sqssample/Main.java +++ b/pekko-connectors-sample-sqs-java/src/main/java/samples/sqssample/Main.java @@ -1,21 +1,21 @@ -package alpakka.sample.sqssample; +package samples.sqssample; -import akka.Done; -import akka.NotUsed; -import akka.actor.typed.ActorRef; -import akka.actor.typed.ActorSystem; -import akka.actor.typed.javadsl.AskPattern; -import akka.stream.alpakka.sqs.*; -import akka.stream.alpakka.sqs.javadsl.SqsAckSink; -import akka.stream.alpakka.sqs.javadsl.SqsPublishFlow; -import akka.stream.alpakka.sqs.javadsl.SqsSource; -import akka.stream.javadsl.Flow; -import akka.stream.javadsl.Sink; -import akka.stream.javadsl.Source; +import org.apache.pekko.Done; +import org.apache.pekko.NotUsed; +import org.apache.pekko.actor.typed.ActorRef; +import org.apache.pekko.actor.typed.ActorSystem; +import org.apache.pekko.actor.typed.javadsl.AskPattern; +import org.apache.pekko.stream.connectors.sqs.*; +import org.apache.pekko.stream.connectors.sqs.javadsl.SqsAckSink; +import org.apache.pekko.stream.connectors.sqs.javadsl.SqsPublishFlow; +import org.apache.pekko.stream.connectors.sqs.javadsl.SqsSource; +import org.apache.pekko.stream.javadsl.Flow; +import org.apache.pekko.stream.javadsl.Sink; +import org.apache.pekko.stream.javadsl.Source; import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectReader; import com.fasterxml.jackson.databind.ObjectWriter; -import com.github.matsluni.akkahttpspi.AkkaHttpClient; +import com.github.pjfanning.pekkohttpspi.PekkoHttpClient; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import software.amazon.awssdk.auth.credentials.AwsBasicCredentials; @@ -31,7 +31,7 @@ import java.net.URI; import java.time.Duration; import java.util.concurrent.CompletionStage; -import static akka.pattern.Patterns.ask; +import static org.apache.pekko.pattern.Patterns.ask; public class Main { @@ -62,7 +62,7 @@ public class Main { StaticCredentialsProvider.create(AwsBasicCredentials.create("x", "x"))) .endpointOverride(URI.create(sqsEndpoint)) .region(Region.EU_CENTRAL_1) - .httpClient(AkkaHttpClient.builder().withActorSystem(system.classicSystem()).build()) + .httpClient(PekkoHttpClient.builder().withActorSystem(system.classicSystem()).build()) .build(); system.getWhenTerminated().thenAccept(notUsed -> sqsClient.close()); diff --git a/pekko-connectors-sample-sqs-java/src/main/java/alpakka/sample/sqssample/MessageFromSqs.java b/pekko-connectors-sample-sqs-java/src/main/java/samples/sqssample/MessageFromSqs.java similarity index 94% rename from pekko-connectors-sample-sqs-java/src/main/java/alpakka/sample/sqssample/MessageFromSqs.java rename to pekko-connectors-sample-sqs-java/src/main/java/samples/sqssample/MessageFromSqs.java index f16b381..c65bfbe 100644 --- a/pekko-connectors-sample-sqs-java/src/main/java/alpakka/sample/sqssample/MessageFromSqs.java +++ b/pekko-connectors-sample-sqs-java/src/main/java/samples/sqssample/MessageFromSqs.java @@ -1,4 +1,4 @@ -package alpakka.sample.sqssample; +package samples.sqssample; import com.fasterxml.jackson.annotation.JsonCreator; import com.fasterxml.jackson.annotation.JsonProperty; diff --git a/pekko-connectors-sample-sqs-java/src/main/java/alpakka/sample/sqssample/PublishToSqs.java b/pekko-connectors-sample-sqs-java/src/main/java/samples/sqssample/PublishToSqs.java similarity index 77% rename from pekko-connectors-sample-sqs-java/src/main/java/alpakka/sample/sqssample/PublishToSqs.java rename to pekko-connectors-sample-sqs-java/src/main/java/samples/sqssample/PublishToSqs.java index b7cba1e..cd8fa68 100644 --- a/pekko-connectors-sample-sqs-java/src/main/java/alpakka/sample/sqssample/PublishToSqs.java +++ b/pekko-connectors-sample-sqs-java/src/main/java/samples/sqssample/PublishToSqs.java @@ -1,20 +1,20 @@ -package alpakka.sample.sqssample; - -import akka.Done; -import akka.actor.typed.ActorSystem; -import akka.actor.typed.javadsl.Behaviors; -import akka.stream.alpakka.sqs.SqsPublishSettings; -import akka.stream.alpakka.sqs.javadsl.SqsPublishFlow; -import akka.stream.javadsl.Sink; -import akka.stream.javadsl.Source; -import com.github.matsluni.akkahttpspi.AkkaHttpClient; +package samples.sqssample; + +import org.apache.pekko.Done; +import org.apache.pekko.actor.typed.ActorSystem; +import org.apache.pekko.actor.typed.javadsl.Behaviors; +import org.apache.pekko.stream.connectors.sqs.SqsPublishSettings; +import org.apache.pekko.stream.connectors.sqs.javadsl.SqsPublishFlow; +import org.apache.pekko.stream.javadsl.Sink; +import org.apache.pekko.stream.javadsl.Source; +import com.github.pjfanning.pekkohttpspi.PekkoHttpClient; import software.amazon.awssdk.auth.credentials.AwsBasicCredentials; import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider; import software.amazon.awssdk.regions.Region; import software.amazon.awssdk.services.sqs.SqsAsyncClient; +import software.amazon.awssdk.services.sqs.model.SendMessageRequest; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import software.amazon.awssdk.services.sqs.model.SendMessageRequest; import java.net.URI; import java.util.concurrent.CompletionStage; @@ -44,11 +44,11 @@ public class PublishToSqs { StaticCredentialsProvider.create(AwsBasicCredentials.create("x", "x"))) .endpointOverride(URI.create(sqsEndpoint)) .region(Region.EU_CENTRAL_1) - .httpClient(AkkaHttpClient.builder().withActorSystem(system.classicSystem()).build()) + .httpClient(PekkoHttpClient.builder().withActorSystem(system.classicSystem()).build()) .build(); system.getWhenTerminated().thenAccept((notUsed) -> sqsClient.close()); - publishMessageToSourceTopic(sqsClient, "{\"id\":423,\"name\":\"Alpakka\"}") + publishMessageToSourceTopic(sqsClient, "{\"id\":423,\"name\":\"Pekko-Connectors\"}") .thenAccept(done -> system.terminate()); } diff --git a/pekko-connectors-sample-sqs-java/src/main/resources/application.conf b/pekko-connectors-sample-sqs-java/src/main/resources/application.conf index 7bdde8d..77117b1 100644 --- a/pekko-connectors-sample-sqs-java/src/main/resources/application.conf +++ b/pekko-connectors-sample-sqs-java/src/main/resources/application.conf @@ -1,5 +1,5 @@ -akka { - loggers = ["akka.event.slf4j.Slf4jLogger"] - logging-filter = "akka.event.slf4j.Slf4jLoggingFilter" +pekko { + loggers = ["org.apache.pekko.event.slf4j.Slf4jLogger"] + logging-filter = "org.apache.pekko.event.slf4j.Slf4jLoggingFilter" loglevel = "DEBUG" } diff --git a/pekko-connectors-sample-sqs-java/src/main/resources/logback.xml b/pekko-connectors-sample-sqs-java/src/main/resources/logback.xml index 50e1aab..e5875d6 100644 --- a/pekko-connectors-sample-sqs-java/src/main/resources/logback.xml +++ b/pekko-connectors-sample-sqs-java/src/main/resources/logback.xml @@ -6,7 +6,7 @@ </encoder> </appender> - <logger name="akka" level="WARN"/> + <logger name="org.apache.pekko" level="WARN"/> <logger name="com.typesafe.sslconfig" level="WARN"/> <root level="debug"> --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
