Packages

object SqsPublishSink

Scala API to create publishing SQS sinks.

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

Value Members

  1. def apply(queueUrl: String, settings: SqsPublishSettings = SqsPublishSettings.Defaults)(implicit sqsClient: SqsAsyncClient): Sink[String, Future[Done]]

    creates a Sink that accepts strings and publishes them as messages to a SQS queue using an SqsAsyncClient

  2. def batch(queueUrl: String, settings: SqsPublishBatchSettings = SqsPublishBatchSettings.Defaults)(implicit sqsClient: SqsAsyncClient): Sink[Iterable[String], Future[Done]]

    creates a Sink that accepts an iterable of strings and publish them as messages in batches to a SQS queue using an SqsAsyncClient

    creates a Sink that accepts an iterable of strings and publish them as messages in batches to a SQS queue using an SqsAsyncClient

    See also

    https://pekko.apache.org/docs/pekko/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin

  3. def batchedMessageSink(queueUrl: String, settings: SqsPublishBatchSettings = SqsPublishBatchSettings.Defaults)(implicit sqsClient: SqsAsyncClient): Sink[Iterable[SendMessageRequest], Future[Done]]

    creates a Sink to publish messages in batches to a SQS queue using an SqsAsyncClient

  4. def grouped(queueUrl: String, settings: SqsPublishGroupedSettings = SqsPublishGroupedSettings.Defaults)(implicit sqsClient: SqsAsyncClient): Sink[String, Future[Done]]

    creates a Sink that groups strings and publishes them as messages in batches to a SQS queue using an SqsAsyncClient

    creates a Sink that groups strings and publishes them as messages in batches to a SQS queue using an SqsAsyncClient

    See also

    https://pekko.apache.org/docs/pekko/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin

  5. def groupedMessageSink(queueUrl: String, settings: SqsPublishGroupedSettings = SqsPublishGroupedSettings.Defaults)(implicit sqsClient: SqsAsyncClient): Sink[SendMessageRequest, Future[Done]]

    creates a Sink that groups messages and publishes them in batches to a SQS queue using an SqsAsyncClient

    creates a Sink that groups messages and publishes them in batches to a SQS queue using an SqsAsyncClient

    See also

    https://pekko.apache.org/docs/pekko/current/stream/operators/Source-or-Flow/groupedWithin.html#groupedwithin

  6. def messageSink(settings: SqsPublishSettings = SqsPublishSettings.Defaults)(implicit sqsClient: SqsAsyncClient): Sink[SendMessageRequest, Future[Done]]

    creates a Sink to publish messages to SQS queues based on the message queue url using an SqsAsyncClient

  7. def messageSink(queueUrl: String)(implicit sqsClient: SqsAsyncClient): Sink[SendMessageRequest, Future[Done]]

    creates a Sink to publish messages to a SQS queue using an SqsAsyncClient

  8. def messageSink(queueUrl: String, settings: SqsPublishSettings)(implicit sqsClient: SqsAsyncClient): Sink[SendMessageRequest, Future[Done]]

    creates a Sink to publish messages to a SQS queue using an SqsAsyncClient