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-connectors-samples.git
The following commit(s) were added to refs/heads/main by this push:
new c5008fb migrate sqs sample (#15)
c5008fb is described below
commit c5008fb8f371451fcd9550c266d40f54578b45ab
Author: PJ Fanning <[email protected]>
AuthorDate: Sat Dec 16 22:30:10 2023 +0100
migrate sqs sample (#15)
---
.../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]
