This is an automated email from the ASF dual-hosted git repository. fmariani pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit a5ddd946e08fdc4e24acc27f11daa23f3c7158ef Author: Croway <[email protected]> AuthorDate: Thu Feb 5 16:58:18 2026 +0100 mongodb - reduce the tested volume to speed up the execution --- .../mongodb/integration/MongoDbTailableCursorConsumerIT.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbTailableCursorConsumerIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbTailableCursorConsumerIT.java index 228b83df62c5..fa7235096baf 100644 --- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbTailableCursorConsumerIT.java +++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbTailableCursorConsumerIT.java @@ -110,13 +110,13 @@ public class MongoDbTailableCursorConsumerIT extends AbstractMongoDbITSupport im } @Test - public void testHundredThousandRecords() throws Exception { + public void testTenThousandRecords() throws Exception { final MockEndpoint mock = contextExtension.getMockEndpoint("mock:test"); mock.expectedMessageCount(1000); context.getRouteController().startRoute("tailableCursorConsumer1"); - // continuous pump of 100000 records, asserting incrementally to reduce + // continuous pump of 10000 records, asserting incrementally to reduce // overhead on the mock endpoint Executors.newSingleThreadExecutor().submit(() -> doLongerInsert(mock)).get(); @@ -125,7 +125,7 @@ public class MongoDbTailableCursorConsumerIT extends AbstractMongoDbITSupport im } private void doLongerInsert(MockEndpoint mock) { - for (int i = 1; i <= 100000; i++) { + for (int i = 1; i <= 10000; i++) { cappedTestCollection.insertOne(new Document("increasing", i).append("string", "value" + i)); // incrementally assert, as the mock endpoint stores all
