(camel) branch main updated: Make SqsConsumerTest more robust

[fmariani]

This is an automated email from the ASF dual-hosted git repository.

fmariani pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 25d8c1a5c4d8 Make SqsConsumerTest more robust
25d8c1a5c4d8 is described below

commit 25d8c1a5c4d87bd56cd84f564ed4425f122ca3f7
Author: Croway <federico.mariani.1...@gmail.com>
AuthorDate: Tue Feb 10 17:25:06 2026 +0100

    Make SqsConsumerTest more robust
---
 .../camel/component/aws2/sqs/Sqs2ConsumerTest.java     | 18 +++++++++++-------
 1 file changed, 11 insertions(+), 7 deletions(-)

diff --git 
a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/Sqs2ConsumerTest.java
 
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/Sqs2ConsumerTest.java
index 4f6df74ebb78..1e0d694b64fc 100644
--- 
a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/Sqs2ConsumerTest.java
+++ 
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/Sqs2ConsumerTest.java
@@ -49,6 +49,7 @@ import static org.assertj.core.api.Assertions.catchException;
 import static org.mockito.Mockito.doReturn;
 import static 
software.amazon.awssdk.services.sqs.model.MessageSystemAttributeName.ALL;
 import static 
software.amazon.awssdk.services.sqs.model.MessageSystemAttributeName.MESSAGE_GROUP_ID;
+import static 
software.amazon.awssdk.services.sqs.model.MessageSystemAttributeName.SENDER_ID;
 import static 
software.amazon.awssdk.services.sqs.model.MessageSystemAttributeName.SENT_TIMESTAMP;
 import static 
software.amazon.awssdk.services.sqs.model.MessageSystemAttributeName.SEQUENCE_NUMBER;
 
@@ -385,6 +386,7 @@ class Sqs2ConsumerTest extends CamelTestSupport {
     void shouldRequest66MessagesWithSevenReceiveRequestSortedBySenderId() 
throws Exception {
         // given
         generateSequenceNumber = false;
+        configuration.setSortAttributeName("SenderId");
         var expectedMessages = IntStream.range(0, 66)
                 .mapToObj(i -> Message.builder()
                         .body(Integer.toString(i))
@@ -401,14 +403,16 @@ class Sqs2ConsumerTest extends CamelTestSupport {
             // then
             assertThat(polledMessagesCount).isEqualTo(66);
             
assertThat(receiveMessageBodies()).containsExactly(expectedMessages.stream().map(Message::body).toArray());
+            var expectedRequest = expectedReceiveRequestBuilder()
+                    .messageSystemAttributeNames(List.of(SENT_TIMESTAMP, 
MESSAGE_GROUP_ID, SENDER_ID));
             
assertThat(sqsClientMock.getReceiveRequests()).containsExactlyInAnyOrder(
-                    expectedReceiveRequest(10),
-                    expectedReceiveRequest(10),
-                    expectedReceiveRequest(10),
-                    expectedReceiveRequest(10),
-                    expectedReceiveRequest(10),
-                    expectedReceiveRequest(10),
-                    expectedReceiveRequest(6));
+                    expectedRequest.maxNumberOfMessages(10).build(),
+                    expectedRequest.maxNumberOfMessages(10).build(),
+                    expectedRequest.maxNumberOfMessages(10).build(),
+                    expectedRequest.maxNumberOfMessages(10).build(),
+                    expectedRequest.maxNumberOfMessages(10).build(),
+                    expectedRequest.maxNumberOfMessages(10).build(),
+                    expectedRequest.maxNumberOfMessages(6).build());
             assertThat(sqsClientMock.getQueues()).isEmpty();
         }
     }