You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2023/08/08 12:09:46 UTC

[camel] branch main updated: (chores) camel-aws2-sqs: fixed flaky test SqsBatchConsumerConcurrentConsumersIT (#11040)

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

orpiske 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 8f9ec3f05bc (chores) camel-aws2-sqs: fixed flaky test SqsBatchConsumerConcurrentConsumersIT (#11040)
8f9ec3f05bc is described below

commit 8f9ec3f05bcf0223bb79c9579ae3039308b4a8cf
Author: Otavio Rodolfo Piske <or...@users.noreply.github.com>
AuthorDate: Tue Aug 8 14:09:39 2023 +0200

    (chores) camel-aws2-sqs: fixed flaky test SqsBatchConsumerConcurrentConsumersIT (#11040)
    
    On some systems, there's a chance that the concurrent consumers will round-robin and, as such, consume all messages sent. Nonetheless, they would still be consumed in batches.
---
 .../camel/component/aws2/sqs/SqsBatchConsumerConcurrentConsumersIT.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsBatchConsumerConcurrentConsumersIT.java b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsBatchConsumerConcurrentConsumersIT.java
index 4e8604f242e..ab5b308a46a 100644
--- a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsBatchConsumerConcurrentConsumersIT.java
+++ b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsBatchConsumerConcurrentConsumersIT.java
@@ -31,7 +31,7 @@ public class SqsBatchConsumerConcurrentConsumersIT extends CamelTestSupport {
 
     @Test
     public void receiveBatch() throws Exception {
-        mock.expectedMessageCount(5);
+        mock.expectedMinimumMessageCount(5);
         MockEndpoint.assertIsSatisfied(context);
     }