AWS SNS
The AWS SNS connector provides an Akka Stream Flow and Sink for push notifications through AWS SNS.
For more information about AWS SNS please visit the official documentation.
Project Info: Alpakka AWS SNS | |
---|---|
Artifact | com.lightbend.akka
akka-stream-alpakka-sns
2.0.2
|
JDK versions | Adopt OpenJDK 8 Adopt OpenJDK 11 |
Scala versions | 2.12.11, 2.11.12, 2.13.3 |
JPMS module name | akka.stream.alpakka.aws.sns |
License | |
Readiness level |
Since 0.8, 2017-05-05
|
Home page | https://doc.akka.io/docs/alpakka/current |
API documentation | |
Forums | |
Release notes | In the documentation |
Issues | Github issues |
Sources | https://github.com/akka/alpakka |
Artifacts
- sbt
val AkkaVersion = "2.5.31" val AkkaHttpVersion = "10.1.11" libraryDependencies ++= Seq( "com.lightbend.akka" %% "akka-stream-alpakka-sns" % "2.0.2", "com.typesafe.akka" %% "akka-stream" % AkkaVersion, "com.typesafe.akka" %% "akka-http" % AkkaHttpVersion )
- Maven
<properties> <akka.version>2.5.31</akka.version> <akka.http.version>10.1.11</akka.http.version> <scala.binary.version>2.12</scala.binary.version> </properties> <dependency> <groupId>com.lightbend.akka</groupId> <artifactId>akka-stream-alpakka-sns_${scala.binary.version}</artifactId> <version>2.0.2</version> </dependency> <dependency> <groupId>com.typesafe.akka</groupId> <artifactId>akka-stream_${scala.binary.version}</artifactId> <version>${akka.version}</version> </dependency> <dependency> <groupId>com.typesafe.akka</groupId> <artifactId>akka-http_${scala.binary.version}</artifactId> <version>${akka.http.version}</version> </dependency>
- Gradle
versions += [ AkkaVersion: "2.5.31", AkkaHttpVersion: "10.1.11", ScalaBinary: "2.12" ] dependencies { compile group: 'com.lightbend.akka', name: "akka-stream-alpakka-sns_${versions.ScalaBinary}", version: '2.0.2', compile group: 'com.typesafe.akka', name: "akka-stream_${versions.ScalaBinary}", version: versions.AkkaVersion, compile group: 'com.typesafe.akka', name: "akka-http_${versions.ScalaBinary}", version: versions.AkkaHttpVersion }
The table below shows direct dependencies of this module and the second tab shows all libraries it depends on transitively.
- Direct dependencies
Organization Artifact Version com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.github.matsluni aws-spi-akka-http_2.12 0.0.9 com.typesafe.akka akka-http_2.12 10.1.11 com.typesafe.akka akka-stream_2.12 2.5.31 org.scala-lang scala-library 2.12.11 software.amazon.awssdk sns 2.11.14 - Dependency tree
com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 com.github.matsluni aws-spi-akka-http_2.12 0.0.9 org.scala-lang scala-library 2.12.11 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 com.typesafe.akka akka-http_2.12 10.1.11 com.typesafe.akka akka-http-core_2.12 10.1.11 com.typesafe.akka akka-parsing_2.12 10.1.11 org.scala-lang scala-library 2.12.11 org.scala-lang scala-library 2.12.11 org.scala-lang scala-library 2.12.11 com.typesafe.akka akka-stream_2.12 2.5.31 com.typesafe.akka akka-actor_2.12 2.5.31 com.typesafe config 1.3.3 org.scala-lang.modules scala-java8-compat_2.12 0.8.0 org.scala-lang scala-library 2.12.11 org.scala-lang scala-library 2.12.11 com.typesafe.akka akka-protobuf_2.12 2.5.31 org.scala-lang scala-library 2.12.11 com.typesafe ssl-config-core_2.12 0.3.8 com.typesafe config 1.3.3 org.scala-lang.modules scala-parser-combinators_2.12 1.1.2 org.scala-lang scala-library 2.12.11 org.scala-lang scala-library 2.12.11 org.reactivestreams reactive-streams 1.0.2 org.scala-lang scala-library 2.12.11 org.scala-lang scala-library 2.12.11 software.amazon.awssdk sns 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk auth 2.11.14 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk regions 2.11.14 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.eventstream eventstream 1.0.1 software.amazon.awssdk aws-core 2.11.14 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk auth 2.11.14 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk regions 2.11.14 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.eventstream eventstream 1.0.1 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk regions 2.11.14 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.eventstream eventstream 1.0.1 software.amazon.awssdk aws-query-protocol 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk aws-core 2.11.14 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk auth 2.11.14 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk regions 2.11.14 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.eventstream eventstream 1.0.1 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk regions 2.11.14 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.eventstream eventstream 1.0.1 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk protocol-core 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk protocol-core 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk regions 2.11.14 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14
Setup
This connector requires an implicit SnsAsyncClient
instance to communicate with AWS SQS.
It is your code’s responsibility to call close
to free any resources held by the client. In this example it will be called when the actor system is terminated.
- Scala
-
import java.net.URI import com.github.matsluni.akkahttpspi.AkkaHttpClient import software.amazon.awssdk.services.sns.SnsAsyncClient import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider import software.amazon.awssdk.auth.credentials.AwsBasicCredentials import software.amazon.awssdk.regions.Region // Don't encode credentials in your source code! // see https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html val credentialsProvider = StaticCredentialsProvider.create(AwsBasicCredentials.create("x", "x")) implicit val awsSnsClient: SnsAsyncClient = SnsAsyncClient .builder() .credentialsProvider(credentialsProvider) .region(Region.EU_CENTRAL_1) .httpClient(AkkaHttpClient.builder().withActorSystem(system).build()) // Possibility to configure the retry policy // see https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html // .overrideConfiguration(...) .build() system.registerOnTermination(awsSnsClient.close())
- Java
-
import java.net.URI; import com.github.matsluni.akkahttpspi.AkkaHttpClient; import org.junit.Rule; 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.sns.SnsAsyncClient; // Don't encode credentials in your source code! // see https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html StaticCredentialsProvider credentialsProvider = StaticCredentialsProvider.create(AwsBasicCredentials.create("x", "x")); final SnsAsyncClient awsSnsClient = SnsAsyncClient.builder() .credentialsProvider(credentialsProvider) .region(Region.EU_CENTRAL_1) .httpClient(AkkaHttpClient.builder().withActorSystem(system).build()) // Possibility to configure the retry policy // see https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html // .overrideConfiguration(...) .build(); system.registerOnTermination(() -> awsSnsClient.close());
The example above uses Akka HTTP as the default HTTP client implementation. For more details about the HTTP client, configuring request retrying and best practices for credentials, see AWS client configuration for more details.
We will also need an ActorSystem
ActorSystem
and an Materializer
Materializer
.
- Scala
-
implicit val system: ActorSystem = ActorSystem() implicit val mat: Materializer = ActorMaterializer()
- Java
-
ActorSystem system = ActorSystem.create(); Materializer materializer = ActorMaterializer.create(system);
This is all preparation that we are going to need.
Publish messages to an SNS topic
Now we can publish a message to any SNS topic where we have access to by providing the topic ARN to the SnsPublisher
SnsPublisher
Flow or Sink factory method.
Using a Flow
- Scala
-
Source .single("message") .via(SnsPublisher.flow(topicArn)) .runWith(Sink.foreach(res => println(res.messageId()))) Source .single(PublishRequest.builder().message("message").build()) .via(SnsPublisher.publishFlow(topicArn)) .runWith(Sink.foreach(res => println(res.messageId()))) Source .single(PublishRequest.builder().message("message").topicArn(topicArn).build()) .via(SnsPublisher.publishFlow()) .runWith(Sink.foreach(res => println(res.messageId())))
- Java
-
Source.single("message") .via(SnsPublisher.createFlow(topicArn, snsClient)) .runWith(Sink.foreach(res -> System.out.println(res.messageId())), materializer); Source.single(PublishRequest.builder().message("message").build()) .via(SnsPublisher.createPublishFlow(topicArn, snsClient)) .runWith(Sink.foreach(res -> System.out.println(res.messageId())), materializer); Source.single(PublishRequest.builder().message("message").topicArn(topicArn).build()) .via(SnsPublisher.createPublishFlow(snsClient)) .runWith(Sink.foreach(res -> System.out.println(res.messageId())), materializer);
As you can see, this would publish the messages from the source to the specified AWS SNS topic. After a message has been successfully published, a PublishResult
will be pushed downstream.
Using a Sink
- Scala
-
Source .single("message") .runWith(SnsPublisher.sink(topicArn)) Source .single(PublishRequest.builder().message("message").build()) .runWith(SnsPublisher.publishSink(topicArn)) Source .single(PublishRequest.builder().message("message").topicArn(topicArn).build()) .runWith(SnsPublisher.publishSink())
- Java
-
Source.single("message") .runWith(SnsPublisher.createSink(topicArn, snsClient), materializer); Source.single(PublishRequest.builder().message("message").build()) .runWith(SnsPublisher.createPublishSink(topicArn, snsClient), materializer); Source.single(PublishRequest.builder().message("message").topicArn(topicArn).build()) .runWith(SnsPublisher.createPublishSink(snsClient), materializer);
As you can see, this would publish the messages from the source to the specified AWS SNS topic.