You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2021/09/30 12:03:05 UTC
[camel] branch main updated: camel-kafka: remove bogus sleeps on
the test code
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 d47f2ff camel-kafka: remove bogus sleeps on the test code
d47f2ff is described below
commit d47f2ff6e6d5427980f38cfd19933eccae7c2153
Author: Otavio Rodolfo Piske <op...@redhat.com>
AuthorDate: Thu Sep 30 13:14:23 2021 +0200
camel-kafka: remove bogus sleeps on the test code
---
.../camel/component/kafka/integration/KafkaConsumerFullIT.java | 5 -----
.../kafka/integration/KafkaConsumerIdempotentTestSupport.java | 2 --
2 files changed, 7 deletions(-)
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java
index b7dd102..f772423 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java
@@ -118,7 +118,6 @@ public class KafkaConsumerFullIT extends BaseEmbeddedKafkaTestSupport {
to.assertIsSatisfied(3000);
- Thread.sleep(1000);
assertEquals(5, StreamSupport.stream(MockConsumerInterceptor.recordsCaptured.get(0).records(TOPIC).spliterator(), false)
.count());
@@ -199,10 +198,6 @@ public class KafkaConsumerFullIT extends BaseEmbeddedKafkaTestSupport {
context.getRouteController().startRoute("full-it");
- // As wee set seek to end we should not re-consume any messages
- synchronized (this) {
- Thread.sleep(1000);
- }
to.assertIsSatisfied(3000);
}
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentTestSupport.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentTestSupport.java
index fed1fee..f42f478 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentTestSupport.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentTestSupport.java
@@ -57,8 +57,6 @@ public abstract class KafkaConsumerIdempotentTestSupport extends BaseEmbeddedKaf
List<Exchange> exchangeList = mockEndpoint.getReceivedExchanges();
- Thread.sleep(5000);
-
mockEndpoint.assertIsSatisfied(10000);
assertEquals(size, exchangeList.size());