Packages

object SnsPublisher

Scala 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 flow(topicArn: String, settings: SnsPublishSettings = SnsPublishSettings())(implicit snsClient: SnsAsyncClient): Flow[String, PublishResponse, NotUsed]

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

  2. def publishFlow()(implicit snsClient: SnsAsyncClient): Flow[PublishRequest, PublishResponse, NotUsed]

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

  3. def publishFlow(settings: SnsPublishSettings)(implicit snsClient: SnsAsyncClient): Flow[PublishRequest, PublishResponse, NotUsed]

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

  4. def publishFlow(topicArn: String, settings: SnsPublishSettings = SnsPublishSettings())(implicit snsClient: SnsAsyncClient): Flow[PublishRequest, PublishResponse, NotUsed]

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

  5. def publishSink()(implicit snsClient: SnsAsyncClient): Sink[PublishRequest, Future[Done]]

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

  6. def publishSink(settings: SnsPublishSettings)(implicit snsClient: SnsAsyncClient): Sink[PublishRequest, Future[Done]]

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

  7. def publishSink(topicArn: String, settings: SnsPublishSettings = SnsPublishSettings())(implicit snsClient: SnsAsyncClient): Sink[PublishRequest, Future[Done]]

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

  8. def sink(topicArn: String, settings: SnsPublishSettings = SnsPublishSettings())(implicit snsClient: SnsAsyncClient): Sink[String, Future[Done]]

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