Packages

object SqsPublishFlow

Java API to create SQS flows.

Annotations
@ApiMayChange()
Source
SqsPublishFlow.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SqsPublishFlow
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def batch[B <: Iterable[SendMessageRequest]](queueUrl: String, settings: SqsPublishBatchSettings, sqsClient: SqsAsyncClient): Flow[B, List[SqsPublishResultEntry], NotUsed]

    creates a Flow to publish messages in batches to a SQS queue using an AmazonSQSAsync

  2. def create(settings: SqsPublishSettings, sqsClient: SqsAsyncClient): Flow[SendMessageRequest, SqsPublishResult, NotUsed]

    creates a Flow to publish messages to SQS queues based on the message queue url using an AmazonSQSAsync

  3. def create(queueUrl: String, settings: SqsPublishSettings, sqsClient: SqsAsyncClient): Flow[SendMessageRequest, SqsPublishResult, NotUsed]

    creates a Flow to publish messages to a SQS queue using an AmazonSQSAsync

  4. def grouped(queueUrl: String, settings: SqsPublishGroupedSettings, sqsClient: SqsAsyncClient): Flow[SendMessageRequest, SqsPublishResultEntry, NotUsed]

    creates a Flow that groups messages and publish them in batches to a SQS queue using an AmazonSQSAsync

    creates a Flow that groups messages and publish them in batches to a SQS queue using an AmazonSQSAsync

    See also

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