Skip to content

SqsPublishFlow.batch never sets delay seconds to SendMessageBatchRequestEntry #3235

@mairon-eero

Description

@mairon-eero

Versions used

Akka version: Any version

Expected Behavior

Delay seconds parameter from SendMessageRequest should be forwarded to the batch requests

Actual Behavior

SendMessageBatchRequestEntry is build without the delay seconds parameter.
https://github.com/akka/alpakka/blob/main/sqs/src/main/scala/akka/stream/alpakka/sqs/scaladsl/SqsPublishFlow.scala#L85

            SendMessageBatchRequestEntry
              .builder()
              .id(i.toString)
              .messageBody(r.messageBody())
              .messageAttributes(r.messageAttributes())
              .messageGroupId(r.messageGroupId())
              .messageDeduplicationId(r.messageDeduplicationId())
              .build()

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions