[camel] branch main updated: (chores) camel-lumberjack: avoid overloading slower nodes in test

[orpiske]

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

orpiske 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 803dc78f789 (chores) camel-lumberjack: avoid overloading slower nodes 
in test
803dc78f789 is described below

commit 803dc78f789b441bba3b3cc74290a89d6c63892b
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Thu Sep 28 09:41:27 2023 +0200

    (chores) camel-lumberjack: avoid overloading slower nodes in test
---
 .../component/lumberjack/LumberjackMultiThreadTest.java   | 15 ++++++++++-----
 1 file changed, 10 insertions(+), 5 deletions(-)

diff --git 
a/components/camel-lumberjack/src/test/java/org/apache/camel/component/lumberjack/LumberjackMultiThreadTest.java
 
b/components/camel-lumberjack/src/test/java/org/apache/camel/component/lumberjack/LumberjackMultiThreadTest.java
index d37c60f7e3c..2f90fa3b409 100644
--- 
a/components/camel-lumberjack/src/test/java/org/apache/camel/component/lumberjack/LumberjackMultiThreadTest.java
+++ 
b/components/camel-lumberjack/src/test/java/org/apache/camel/component/lumberjack/LumberjackMultiThreadTest.java
@@ -29,10 +29,12 @@ import org.apache.camel.test.junit5.CamelTestSupport;
 import org.awaitility.Awaitility;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.parallel.Isolated;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.fail;
 
+@Isolated
 public class LumberjackMultiThreadTest extends CamelTestSupport {
 
     private static int port;
@@ -54,21 +56,24 @@ public class LumberjackMultiThreadTest extends 
CamelTestSupport {
 
     @Test
     public void shouldListenToMessages() throws Exception {
-        // We're expecting 25 messages with Maps
+        int concurrencyLevel = 
Math.min(Runtime.getRuntime().availableProcessors(), 4);
+
+        // We're expecting 25 messages with Maps for each thread
         MockEndpoint mock = getMockEndpoint("mock:output");
-        mock.expectedMessageCount(125);
+        mock.expectedMessageCount(25 * concurrencyLevel);
         mock.allMessages().body().isInstanceOf(Map.class);
 
         // When sending messages
         List<Integer> windows = Arrays.asList(15, 10);
 
-        // create 5 threads
+        // create a number of threads
         List<LumberjackThreadTest> threads = new ArrayList<>();
-        for (int i = 0; i < 5; i++) {
+
+        for (int i = 0; i < concurrencyLevel; i++) {
             threads.add(new LumberjackThreadTest());
         }
 
-        // sending messages on 5 parallel sessions
+        // sending messages on all parallel sessions
         threads.stream().forEach(thread -> thread.start());
 
         // Then we should have the messages we're expecting