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 d5ad72971512d..c281921326c90 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 @@ private void doSendMessages(int files, int poolSize) throws Exception { 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 3eb0c60859b23..d3c659771519e 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 @@ private void doSendMessages(int files, int poolSize) throws Exception { executor.submit(new Callable() { 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 183415fe75aaf..5b6a1367af521 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 void testLoadAndRecoverLevelDBAggregate() throws Exception { 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 cd675ddfe94d2..abf9d3eeedd7b 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 Object call() throws Exception { 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 36ff502a07c1d..a8ad3c0ecb5fc 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 void testExisting() throws Exception { // 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 fcbce5ca81c5d..427be833fd8af 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 void testExisting() throws Exception { // stop the repo repo.stop(); - Thread.sleep(1000); - // load the repo again repo.start();