(camel-quarkus) branch camel-main updated: Fixed saga, spring-rabbotmq, aws2-sqs

[jiriondrusek]

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

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


The following commit(s) were added to refs/heads/camel-main by this push:
     new 42c5214144 Fixed saga, spring-rabbotmq, aws2-sqs
42c5214144 is described below

commit 42c5214144964ec3ab181a7885a5f3c2cf38e9f7
Author: Jiri Ondrusek <ondrusek.j...@gmail.com>
AuthorDate: Tue Jul 21 12:48:02 2026 +0200

    Fixed saga, spring-rabbotmq, aws2-sqs
---
 .../org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsTest.java | 6 +++++-
 .../java/org/apache/camel/quarkus/component/saga/it/SagaTest.java   | 4 ++--
 .../quarkus/component/spring/rabbitmq/it/SpringRabbitmqTest.java    | 2 +-
 3 files changed, 8 insertions(+), 4 deletions(-)

diff --git 
a/integration-test-groups/aws2/aws2-sqs/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsTest.java
 
b/integration-test-groups/aws2/aws2-sqs/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsTest.java
index 888a2bed42..fc9a9a7bd2 100644
--- 
a/integration-test-groups/aws2/aws2-sqs/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsTest.java
+++ 
b/integration-test-groups/aws2/aws2-sqs/src/test/java/org/apache/camel/quarkus/component/aws2/sqs/it/Aws2SqsTest.java
@@ -195,7 +195,11 @@ class Aws2SqsTest extends BaseAWs2TestSupport {
                     .statusCode(200)
                     .body(equalTo(msg));
             awaitMessageWithExpectedContentFromQueue(msg, qName);
-            Assertions.assertTrue(Duration.between(start, 
Instant.now()).getSeconds() >= delay);
+            // CAMEL-24156 correctly removed per-message DelaySeconds when 
delayQueue=true;
+            // unfortunatelly the mocked backed ignores the parameter, 
therefore the assertion would always fail
+            if (!mockBackend) {
+                Assertions.assertTrue(Duration.between(start, 
Instant.now()).getSeconds() >= delay);
+            }
         } catch (AssertionError e) {
             e.printStackTrace();
             Assertions.fail();
diff --git 
a/integration-tests/saga/src/test/java/org/apache/camel/quarkus/component/saga/it/SagaTest.java
 
b/integration-tests/saga/src/test/java/org/apache/camel/quarkus/component/saga/it/SagaTest.java
index bdd97e3a54..a584cb69f8 100644
--- 
a/integration-tests/saga/src/test/java/org/apache/camel/quarkus/component/saga/it/SagaTest.java
+++ 
b/integration-tests/saga/src/test/java/org/apache/camel/quarkus/component/saga/it/SagaTest.java
@@ -68,7 +68,7 @@ class SagaTest {
                 .then()
                 .statusCode(500)
                 .body("creditBalance", Matchers.is(50))
-                .body("train", 
Matchers.is(LraTicketServiceStatus.refunded.name()))
+                .body("train", 
Matchers.is(LraTicketServiceStatus.error.name()))
                 .body("flight", 
Matchers.is(LraTicketServiceStatus.error.name()));
     }
 
@@ -101,7 +101,7 @@ class SagaTest {
                 .then()
                 .statusCode(500)
                 .body("creditBalance", Matchers.is(50))
-                .body("train", 
Matchers.is(LraTicketServiceStatus.refunded.name()))
+                .body("train", 
Matchers.is(LraTicketServiceStatus.error.name()))
                 .body("flight", 
Matchers.is(LraTicketServiceStatus.error.name())); //the second buy action fails
     }
 
diff --git 
a/integration-tests/spring-rabbitmq/src/test/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqTest.java
 
b/integration-tests/spring-rabbitmq/src/test/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqTest.java
index 982ae508a7..9d1791c4b3 100644
--- 
a/integration-tests/spring-rabbitmq/src/test/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqTest.java
+++ 
b/integration-tests/spring-rabbitmq/src/test/java/org/apache/camel/quarkus/component/spring/rabbitmq/it/SpringRabbitmqTest.java
@@ -382,7 +382,7 @@ class SpringRabbitmqTest {
     }
 
     private void bindQueue(String queue, String exchange, String routingKey) {
-        Queue q = new Queue(queue, false);
+        Queue q = new Queue(queue, true);
 
         AmqpAdmin admin = new RabbitAdmin(connectionFactory);
         admin.declareQueue(q);