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 bf5e6f5f2cc86a9cd631a5f0df2d5ac14b987fdb Author: Jiri Ondrusek <[email protected]> AuthorDate: Fri Feb 27 14:40:31 2026 +0100 Fixed spring-rabbitmq --- integration-tests/spring-rabbitmq/pom.xml | 5 +++++ .../component/spring/rabbitmq/it/SpringRabbitmqTest.java | 13 ++++++++----- pom.xml | 2 +- 3 files changed, 14 insertions(+), 6 deletions(-) diff --git a/integration-tests/spring-rabbitmq/pom.xml b/integration-tests/spring-rabbitmq/pom.xml index c2f9694571..f03b869df8 100644 --- a/integration-tests/spring-rabbitmq/pom.xml +++ b/integration-tests/spring-rabbitmq/pom.xml @@ -70,6 +70,11 @@ <artifactId>assertj-core</artifactId> <scope>test</scope> </dependency> + <dependency> + <groupId>org.awaitility</groupId> + <artifactId>awaitility</artifactId> + <scope>test</scope> + </dependency> </dependencies> <profiles> 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 73bba8c7e8..6c13844385 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 @@ -29,6 +29,7 @@ import io.restassured.response.Response; import io.restassured.specification.RequestSpecification; import org.apache.camel.component.springrabbit.SpringRabbitMQConstants; import org.awaitility.Awaitility; +import org.hamcrest.Matchers; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Test; import org.springframework.amqp.core.AmqpAdmin; @@ -347,11 +348,13 @@ class SpringRabbitmqTest { .then() .statusCode(204); - //message ends in deadletter - getFromDirect("direct:deadletter-DL") - .then() - .statusCode(200) - .body(is("Hello from deadletter: Hello")); + //stop route (and wait for stop) + Awaitility.await().atMost(30, TimeUnit.SECONDS).until( + () -> getFromDirect("direct:deadletter-DL") + .then() + .statusCode(200) + .extract().asString(), + Matchers.is("Hello from deadletter: Hello")); //no message ends in the "successful scenario" direct getFromDirect("direct:deadletter") diff --git a/pom.xml b/pom.xml index 6bc55891b5..ff0261c869 100644 --- a/pom.xml +++ b/pom.xml @@ -276,7 +276,7 @@ <postgres.container.image>mirror.gcr.io/postgres:17.5</postgres.container.image> <postgres-debezium.container.image>quay.io/debezium/postgres:17-alpine</postgres-debezium.container.image> <qdrant.container.image>mirror.gcr.io/qdrant/qdrant:v1.16.0-unprivileged</qdrant.container.image> - <rabbitmq.container.image>mirror.gcr.io/rabbitmq:4.1.2-management-alpine</rabbitmq.container.image> + <rabbitmq.container.image>mirror.gcr.io/rabbitmq:management-alpine</rabbitmq.container.image> <redis.container.image>mirror.gcr.io/redis:7.4.0-alpine</redis.container.image> <servicebus-emulator.container.image>mcr.microsoft.com/azure-messaging/servicebus-emulator:latest</servicebus-emulator.container.image> <smb.container.image>quay.io/jamesnetherton/camel-smb-test-server:1.0.0</smb.container.image>
