You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ji...@apache.org on 2026/03/18 10:54:18 UTC
(camel-quarkus) 10/26: Fixed spring-rabbitmq
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 0e6e90cd2acc05235f8ac1bdd2f90818e9d07941
Author: Jiri Ondrusek <on...@gmail.com>
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 9fe541b25b..c5eae28d7a 100644
--- a/pom.xml
+++ b/pom.xml
@@ -278,7 +278,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>