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 56058a633fb0 CAMEL-19531: Remove unnecessary Thread.sleep calls from
leveldb tests
56058a633fb0 is described below
commit 56058a633fb0c92db2f0f3ef238a011c8b0a82d6
Author: Anvith S G <[email protected]>
AuthorDate: Wed Jun 24 10:36:48 2026 +0530
CAMEL-19531: Remove unnecessary Thread.sleep calls from leveldb tests
Remove six Thread.sleep() calls from camel-leveldb tests: trivial 3-5ms
delays in concurrent aggregation test Callables, and unnecessary 1-second
waits between synchronous stop/start of LevelDBFile and repository.
Closes #24203
---
.../leveldb/LevelDBAggregateConcurrentDifferentGroupsTest.java | 2 --
.../component/leveldb/LevelDBAggregateConcurrentSameGroupTest.java | 2 --
.../camel/component/leveldb/LevelDBAggregateLoadAndRecoverTest.java | 2 --
.../camel/component/leveldb/LevelDBAggregateLoadConcurrentTest.java | 2 --
.../component/leveldb/LevelDBAggregationRepositoryLoadExistingTest.java | 2 --
.../leveldb/LevelDBAggregationRepositoryRecoverExistingTest.java | 2 --
6 files changed, 12 deletions(-)
diff --git
a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateConcurrentDifferentGroupsTest.java
b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateConcurrentDifferentGroupsTest.java
index d5ad72971512..c281921326c9 100644
---
a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateConcurrentDifferentGroupsTest.java
+++
b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateConcurrentDifferentGroupsTest.java
@@ -63,8 +63,6 @@ public class LevelDBAggregateConcurrentDifferentGroupsTest
extends LevelDBTestSu
public Object call() throws Exception {
String id = index % 2 == 0 ? "A" : "B";
template.sendBodyAndHeader("direct:start", index, "id",
id);
- // simulate a little delay
- Thread.sleep(3);
return null;
}
});
diff --git
a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateConcurrentSameGroupTest.java
b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateConcurrentSameGroupTest.java
index 3eb0c60859b2..d3c659771519 100644
---
a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateConcurrentSameGroupTest.java
+++
b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateConcurrentSameGroupTest.java
@@ -62,8 +62,6 @@ public class LevelDBAggregateConcurrentSameGroupTest extends
LevelDBTestSupport
executor.submit(new Callable<Object>() {
public Object call() throws Exception {
template.sendBodyAndHeader("direct:start", index, "id",
123);
- // simulate a little delay
- Thread.sleep(3);
return null;
}
});
diff --git
a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadAndRecoverTest.java
b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadAndRecoverTest.java
index 183415fe75aa..5b6a1367af52 100644
---
a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadAndRecoverTest.java
+++
b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadAndRecoverTest.java
@@ -65,8 +65,6 @@ public class LevelDBAggregateLoadAndRecoverTest extends
LevelDBTestSupport {
headers.put("seq", i);
LOG.debug("Sending {} with id {}", value, id);
template.sendBodyAndHeaders("seda:start", value, headers);
- // simulate a little delay
- Thread.sleep(5);
}
LOG.info("Sending all {} message done. Now waiting for aggregation to
complete.", SIZE);
diff --git
a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadConcurrentTest.java
b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadConcurrentTest.java
index cd675ddfe94d..abf9d3eeedd7 100644
---
a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadConcurrentTest.java
+++
b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateLoadConcurrentTest.java
@@ -62,8 +62,6 @@ public class LevelDBAggregateLoadConcurrentTest extends
LevelDBTestSupport {
char id = KEYS[key];
LOG.debug("Sending {} with id {}", value, id);
template.sendBodyAndHeader("direct:start", value, "id",
Character.toString(id));
- // simulate a little delay
- Thread.sleep(3);
return null;
}
});
diff --git
a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregationRepositoryLoadExistingTest.java
b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregationRepositoryLoadExistingTest.java
index 36ff502a07c1..a8ad3c0ecb5f 100644
---
a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregationRepositoryLoadExistingTest.java
+++
b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregationRepositoryLoadExistingTest.java
@@ -63,8 +63,6 @@ public class LevelDBAggregationRepositoryLoadExistingTest
extends LevelDBTestSup
// stop the repo
levelDBFile.stop();
- Thread.sleep(1000);
-
// load the repo again
levelDBFile.start();
diff --git
a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregationRepositoryRecoverExistingTest.java
b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregationRepositoryRecoverExistingTest.java
index fcbce5ca81c5..427be833fd8a 100644
---
a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregationRepositoryRecoverExistingTest.java
+++
b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregationRepositoryRecoverExistingTest.java
@@ -65,8 +65,6 @@ public class LevelDBAggregationRepositoryRecoverExistingTest
extends LevelDBTest
// stop the repo
repo.stop();
- Thread.sleep(1000);
-
// load the repo again
repo.start();
