(camel) branch main updated: Flaky 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 9f4a2ed6a36 Flaky test
9f4a2ed6a36 is described below

commit 9f4a2ed6a36abf5fc41e5c43bf6c37f08e1055d3
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Feb 6 21:26:02 2025 +0100

    Flaky test
---
 .../camel/impl/LimitedPollingConsumerPollStrategyTest.java       | 9 +++------
 1 file changed, 3 insertions(+), 6 deletions(-)

diff --git 
a/core/camel-core/src/test/java/org/apache/camel/impl/LimitedPollingConsumerPollStrategyTest.java
 
b/core/camel-core/src/test/java/org/apache/camel/impl/LimitedPollingConsumerPollStrategyTest.java
index 4b66df6a02f..a3236cc83a9 100644
--- 
a/core/camel-core/src/test/java/org/apache/camel/impl/LimitedPollingConsumerPollStrategyTest.java
+++ 
b/core/camel-core/src/test/java/org/apache/camel/impl/LimitedPollingConsumerPollStrategyTest.java
@@ -43,11 +43,11 @@ public class LimitedPollingConsumerPollStrategyTest extends 
ContextTestSupport {
         consumer.setPollStrategy(strategy);
 
         consumer.start();
+        assertTrue(consumer.isStarted(), "Should be started");
 
         consumer.run();
         assertTrue(consumer.isStarted(), "Should still be started");
         consumer.run();
-        assertTrue(consumer.isStarted(), "Should still be started");
         consumer.run();
         assertTrue(consumer.isSuspended(), "Should be suspended");
 
@@ -66,9 +66,9 @@ public class LimitedPollingConsumerPollStrategyTest extends 
ContextTestSupport {
         consumer.setPollStrategy(strategy);
 
         consumer.start();
+        assertTrue(consumer.isStarted(), "Should still be started");
 
         consumer.run();
-        assertTrue(consumer.isStarted(), "Should still be started");
         consumer.run();
         assertTrue(consumer.isSuspended(), "Should be suspended");
 
@@ -87,9 +87,9 @@ public class LimitedPollingConsumerPollStrategyTest extends 
ContextTestSupport {
         consumer.setPollStrategy(strategy);
 
         consumer.start();
+        assertTrue(consumer.isStarted(), "Should be started");
 
         consumer.run();
-        assertTrue(consumer.isStarted(), "Should still be started");
         consumer.run();
         assertTrue(consumer.isStarted(), "Should still be started");
 
@@ -134,7 +134,6 @@ public class LimitedPollingConsumerPollStrategyTest extends 
ContextTestSupport {
         consumer.run();
         assertTrue(consumer.isStarted(), "Should still be started");
         consumer.run();
-        assertTrue(consumer.isStarted(), "Should still be started");
         consumer.run();
         assertTrue(consumer.isSuspended(), "Should be suspended");
 
@@ -191,7 +190,6 @@ public class LimitedPollingConsumerPollStrategyTest extends 
ContextTestSupport {
         consumer.run();
         assertTrue(consumer.isStarted(), "Should still be started");
         consumer.run();
-        assertTrue(consumer.isStarted(), "Should still be started");
         consumer.run();
         assertTrue(consumer.isSuspended(), "Should be suspended");
 
@@ -201,7 +199,6 @@ public class LimitedPollingConsumerPollStrategyTest extends 
ContextTestSupport {
         consumer.run();
         assertTrue(consumer.isStarted(), "Should still be started");
         consumer.run();
-        assertTrue(consumer.isStarted(), "Should still be started");
         consumer.run();
         assertTrue(consumer.isSuspended(), "Should be suspended");