Packages

object SnsPublisher

Java API Amazon SNS publisher factory.

Source
SnsPublisher.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SnsPublisher
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def createFlow(topicArn: String, snsClient: SnsAsyncClient): Flow[String, PublishResponse, NotUsed]

    creates a Flow to publish messages to a SNS topic using an SnsAsyncClient

  2. def createFlow(topicArn: String, settings: SnsPublishSettings, snsClient: SnsAsyncClient): Flow[String, PublishResponse, NotUsed]

    creates a Flow to publish messages to a SNS topic using an SnsAsyncClient

  3. def createPublishFlow(snsClient: SnsAsyncClient): Flow[PublishRequest, PublishResponse, NotUsed]

    creates a Flow to publish messages to a SNS topics based on the message topic arn using an SnsAsyncClient

  4. def createPublishFlow(settings: SnsPublishSettings, snsClient: SnsAsyncClient): Flow[PublishRequest, PublishResponse, NotUsed]

    creates a Flow to publish messages to a SNS topics based on the message topic arn using an SnsAsyncClient

  5. def createPublishFlow(topicArn: String, snsClient: SnsAsyncClient): Flow[PublishRequest, PublishResponse, NotUsed]

    creates a Flow to publish messages to a SNS topic using an SnsAsyncClient

  6. def createPublishFlow(topicArn: String, settings: SnsPublishSettings, snsClient: SnsAsyncClient): Flow[PublishRequest, PublishResponse, NotUsed]

    creates a Flow to publish messages to a SNS topic using an SnsAsyncClient

  7. def createPublishSink(snsClient: SnsAsyncClient): Sink[PublishRequest, CompletionStage[Done]]

    creates a Sink to publish messages to a SNS topics based on the message topic arn using an SnsAsyncClient

  8. def createPublishSink(settings: SnsPublishSettings, snsClient: SnsAsyncClient): Sink[PublishRequest, CompletionStage[Done]]

    creates a Sink to publish messages to a SNS topics based on the message topic arn using an SnsAsyncClient

  9. def createPublishSink(topicArn: String, snsClient: SnsAsyncClient): Sink[PublishRequest, CompletionStage[Done]]

    creates a Sink to publish messages to a SNS topic using an SnsAsyncClient

  10. def createPublishSink(topicArn: String, settings: SnsPublishSettings, snsClient: SnsAsyncClient): Sink[PublishRequest, CompletionStage[Done]]

    creates a Sink to publish messages to a SNS topic using an SnsAsyncClient

  11. def createSink(topicArn: String, snsClient: SnsAsyncClient): Sink[String, CompletionStage[Done]]

    creates a Sink to publish messages to a SNS topic using an SnsAsyncClient

  12. def createSink(topicArn: String, settings: SnsPublishSettings, snsClient: SnsAsyncClient): Sink[String, CompletionStage[Done]]

    creates a Sink to publish messages to a SNS topic using an SnsAsyncClient