llazanja commented on code in PR #760:
URL: https://github.com/apache/pekko-connectors/pull/760#discussion_r1698679738
##########
sqs/src/test/scala/docs/scaladsl/SqsPublishSpec.scala:
##########
@@ -191,6 +197,28 @@ class SqsPublishSpec extends AnyFlatSpec with Matchers
with DefaultTestContext w
}
}
+ it should "publish batch of SendMessageRequests with individual delays and
pull empty seq" taggedAs Integration in {
+ new IntegrationFixture {
+ // #batch-send-request
+ val messages = for (i <- 0 until 10)
+ yield
+ SendMessageRequest
+ .builder()
+ .messageBody(s"Message - $i")
+ .delaySeconds(60) // SQS queue should process messages after 60
seconds
Review Comment:
Done, it took me a bit of time because I couldn't realize why the request to
the SQS queue didn't want to wait at all.
The issue was in the `receiveMessages` method. Wait time has to be specified
in the SQS client request.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscr...@pekko.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@pekko.apache.org
For additional commands, e-mail: notifications-h...@pekko.apache.org
