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 072368b0961 Flaky test 072368b0961 is described below commit 072368b0961d378c7584d4cf0299b7453a7c51df Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Thu Jan 2 14:58:14 2025 +0100 Flaky test --- .../camel/component/file/FileBrowsableEndpointTest.java | 15 +++------------ 1 file changed, 3 insertions(+), 12 deletions(-) diff --git a/core/camel-core/src/test/java/org/apache/camel/component/file/FileBrowsableEndpointTest.java b/core/camel-core/src/test/java/org/apache/camel/component/file/FileBrowsableEndpointTest.java index 10bd53d2193..7da8aa185fd 100644 --- a/core/camel-core/src/test/java/org/apache/camel/component/file/FileBrowsableEndpointTest.java +++ b/core/camel-core/src/test/java/org/apache/camel/component/file/FileBrowsableEndpointTest.java @@ -31,10 +31,8 @@ import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertNotNull; import static org.junit.jupiter.api.Assertions.assertTrue; -/** - * - */ public class FileBrowsableEndpointTest extends ContextTestSupport { + private static final String TEST_FILE_NAME_PREFIX = UUID.randomUUID().toString(); @Test @@ -77,7 +75,7 @@ public class FileBrowsableEndpointTest extends ContextTestSupport { template.sendBodyAndHeader(fileUri(), "B", Exchange.FILE_NAME, TEST_FILE_NAME_PREFIX + "b.txt"); FileEndpoint endpoint - = context.getEndpoint(fileUri("?initialDelay=0&delay=10&sortBy=file:name"), FileEndpoint.class); + = context.getEndpoint(fileUri("?initialDelay=0&delay=10"), FileEndpoint.class); assertNotNull(endpoint); MemoryIdempotentRepository repo = (MemoryIdempotentRepository) endpoint.getInProgressRepository(); @@ -87,9 +85,6 @@ public class FileBrowsableEndpointTest extends ContextTestSupport { assertNotNull(list); assertEquals(2, list.size()); - assertEquals(TEST_FILE_NAME_PREFIX + "a.txt", list.get(0).getIn().getHeader(Exchange.FILE_NAME)); - assertEquals(TEST_FILE_NAME_PREFIX + "b.txt", list.get(1).getIn().getHeader(Exchange.FILE_NAME)); - // the in progress repo should not leak assertEquals(0, repo.getCacheSize()); @@ -107,7 +102,7 @@ public class FileBrowsableEndpointTest extends ContextTestSupport { "bar" + File.separator + TEST_FILE_NAME_PREFIX + "c.txt"); FileEndpoint endpoint = context.getEndpoint( - fileUri("?initialDelay=0&delay=10&recursive=true&sortBy=file:name"), FileEndpoint.class); + fileUri("?initialDelay=0&delay=10&recursive=true"), FileEndpoint.class); assertNotNull(endpoint); MemoryIdempotentRepository repo = (MemoryIdempotentRepository) endpoint.getInProgressRepository(); @@ -117,10 +112,6 @@ public class FileBrowsableEndpointTest extends ContextTestSupport { assertNotNull(list); assertEquals(3, list.size()); - assertEquals(TEST_FILE_NAME_PREFIX + "a.txt", list.get(0).getIn().getHeader(Exchange.FILE_NAME)); - assertEquals(TEST_FILE_NAME_PREFIX + "c.txt", list.get(1).getIn().getHeader(Exchange.FILE_NAME_ONLY)); - assertEquals(TEST_FILE_NAME_PREFIX + "b.txt", list.get(2).getIn().getHeader(Exchange.FILE_NAME_ONLY)); - // the in progress repo should not leak assertEquals(0, repo.getCacheSize());