SqsPublishFlow.batch never sets delay seconds to SendMessageBatchRequestEntry

[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()

[ennru]

Thanks for reporting, feel free to suggest a pull request to set the attribute properly.

[mairon-eero]

@ennru I believe the only thing needed to the code above is:

            SendMessageBatchRequestEntry
              .builder()
              .id(i.toString)
              .messageBody(r.messageBody())
              .messageAttributes(r.messageAttributes())
              .messageGroupId(r.messageGroupId())
              .messageDeduplicationId(r.messageDeduplicationId())
              // Add this new line
              .delaySeconds(r.delaySeconds())
              .build()

[ennru]

Added with

• AWS SQS: copy delay seconds on batch request #3252