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
commit d7382447d684518c6b859a5931c87ab4c62cbb86 Author: Jiri Ondrusek <[email protected]> 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);
