(camel-quarkus) branch main updated: Assert the correct number of expected messages in DataSetTest.simpleDataSetConsumer

[jamesnetherton]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new adccc2bde9 Assert the correct number of expected messages in 
DataSetTest.simpleDataSetConsumer
adccc2bde9 is described below

commit adccc2bde98861f7d5f26ecfc015907870c42fa4
Author: James Netherton <jamesnether...@gmail.com>
AuthorDate: Wed Feb 14 15:49:38 2024 +0000

    Assert the correct number of expected messages in 
DataSetTest.simpleDataSetConsumer
    
    Fixes #5695
---
 .../apache/camel/quarkus/component/dataset/it/DataSetResource.java | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/integration-test-groups/foundation/dataset/src/main/java/org/apache/camel/quarkus/component/dataset/it/DataSetResource.java
 
b/integration-test-groups/foundation/dataset/src/main/java/org/apache/camel/quarkus/component/dataset/it/DataSetResource.java
index 03652621cf..869167940f 100644
--- 
a/integration-test-groups/foundation/dataset/src/main/java/org/apache/camel/quarkus/component/dataset/it/DataSetResource.java
+++ 
b/integration-test-groups/foundation/dataset/src/main/java/org/apache/camel/quarkus/component/dataset/it/DataSetResource.java
@@ -96,8 +96,13 @@ public class DataSetResource {
     @GET
     @Path("/simple/consumer")
     public void dataSetSimpleConsumer() throws Exception {
+        SimpleDataSet simpleDataSet = CamelContextHelper.lookup(context, 
"simpleDataSetForConsumer", SimpleDataSet.class);
         MockEndpoint endpoint = 
context.getEndpoint("mock:simpleDataSetResult", MockEndpoint.class);
-        endpoint.expectedBodiesReceived("<hello>world!</hello>");
+        endpoint.expectedMessageCount((int) simpleDataSet.getSize());
+        endpoint.expectedMessagesMatches(exchange -> {
+            String body = exchange.getMessage().getBody(String.class);
+            return body != null && body.equals("<hello>world!</hello>");
+        });
 
         context.getRouteController().startRoute("simple");
         try {