(camel) branch main updated: Fixed test

[davsclaus]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new 13068c40a3f Fixed test
13068c40a3f is described below

commit 13068c40a3f3e50854126cf238b944f115672787
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Tue Jul 2 09:18:53 2024 +0200

    Fixed test
---
 .../camel/processor/SplitterParallelAggregateManualTest.java       | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git 
a/core/camel-core/src/test/java/org/apache/camel/processor/SplitterParallelAggregateManualTest.java
 
b/core/camel-core/src/test/java/org/apache/camel/processor/SplitterParallelAggregateManualTest.java
index e3d2e16d7d8..3a0990af5d8 100644
--- 
a/core/camel-core/src/test/java/org/apache/camel/processor/SplitterParallelAggregateManualTest.java
+++ 
b/core/camel-core/src/test/java/org/apache/camel/processor/SplitterParallelAggregateManualTest.java
@@ -16,7 +16,6 @@
  */
 package org.apache.camel.processor;
 
-import java.io.File;
 import java.util.ArrayList;
 import java.util.Iterator;
 import java.util.LinkedList;
@@ -71,17 +70,17 @@ public class SplitterParallelAggregateManualTest extends 
ContextTestSupport {
 
     protected void timeSplitRoutes(int numberOfRequests) throws Exception {
         String[] endpoints = new String[] { 
"direct:splitSynchronizedAggregation", "direct:splitUnsynchronizedAggregation" 
};
-        List<Future<File>> futures = new ArrayList<>();
+        List<Future<String>> futures = new ArrayList<>();
         StopWatch stopWatch = new StopWatch(false);
 
         for (String endpoint : endpoints) {
             stopWatch.restart();
             for (int requestIndex = 0; requestIndex < numberOfRequests; 
requestIndex++) {
-                futures.add(template.asyncRequestBody(endpoint, null, 
File.class));
+                futures.add(template.asyncRequestBody(endpoint, null, 
String.class));
             }
 
             for (int i = 0; i < futures.size(); i++) {
-                Future<File> future = futures.get(i);
+                Future<String> future = futures.get(i);
                 future.get();
             }
             stopWatch.taken();