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 2025/07/30 07:08:33 UTC
(camel-quarkus) branch camel-main updated: Added await into spring-rebbitmq to see result on CI
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 dd0c10ea66 Added await into spring-rebbitmq to see result on CI
dd0c10ea66 is described below
commit dd0c10ea66dfb8abc21f6402e590a873bc6e911d
Author: Jiri Ondrusek <on...@gmail.com>
AuthorDate: Wed Jul 30 09:08:08 2025 +0200
Added await into spring-rebbitmq to see result on CI
---
.../spring/rabbitmq/it/SpringRabbitmqTest.java | 33 ++++++++++++----------
1 file changed, 18 insertions(+), 15 deletions(-)
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 33153ba8f4..73bba8c7e8 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
@@ -92,21 +92,24 @@ class SpringRabbitmqTest {
.post("/spring-rabbitmq/send").then().statusCode(204);
AmqpTemplate template = new RabbitTemplate(connectionFactory);
- Message out = template.receive("queue-for-headersToProperties");
-
- final MessageProperties messageProperties = out.getMessageProperties();
- Assertions.assertNotNull(messageProperties, "The message properties should not be null");
- String encoding = messageProperties.getContentEncoding();
- assertThat(Charset.defaultCharset().name()).isEqualTo(encoding);
- assertThat(new String(out.getBody(), encoding)).isEqualTo("<price>123</price>");
- assertThat(messageProperties.getReceivedDeliveryMode()).isEqualTo(MessageDeliveryMode.PERSISTENT);
- assertThat(messageProperties.getType()).isEqualTo("price");
- assertThat(messageProperties.getContentType()).isEqualTo("application/xml");
- assertThat(messageProperties.getMessageId()).isEqualTo("0fe9c142-f9c1-426f-9237-f5a4c988a8ae");
- assertThat(messageProperties.getPriority()).isEqualTo(1);
- //the only headers preserved by customHeadersFilterStrategy is "CamelSpringRabbitmqMessageId
- assertThat(messageProperties.getHeaders().size()).isEqualTo(1);
- assertThat(messageProperties.getHeaders()).containsKey("CamelSpringRabbitmqMessageId");
+
+ Awaitility.await().pollDelay(1, TimeUnit.SECONDS).atMost(30, TimeUnit.SECONDS).untilAsserted(() -> {
+ Message out = template.receive("queue-for-headersToProperties");
+
+ final MessageProperties messageProperties = out.getMessageProperties();
+ Assertions.assertNotNull(messageProperties, "The message properties should not be null");
+ String encoding = messageProperties.getContentEncoding();
+ assertThat(Charset.defaultCharset().name()).isEqualTo(encoding);
+ assertThat(new String(out.getBody(), encoding)).isEqualTo("<price>123</price>");
+ assertThat(messageProperties.getReceivedDeliveryMode()).isEqualTo(MessageDeliveryMode.PERSISTENT);
+ assertThat(messageProperties.getType()).isEqualTo("price");
+ assertThat(messageProperties.getContentType()).isEqualTo("application/xml");
+ assertThat(messageProperties.getMessageId()).isEqualTo("0fe9c142-f9c1-426f-9237-f5a4c988a8ae");
+ assertThat(messageProperties.getPriority()).isEqualTo(1);
+ //the only headers preserved by customHeadersFilterStrategy is "CamelSpringRabbitmqMessageId
+ assertThat(messageProperties.getHeaders().size()).isEqualTo(1);
+ assertThat(messageProperties.getHeaders()).containsKey("CamelSpringRabbitmqMessageId");
+ });
}
@Test