[camel] 03/04: (chores) camel-ignite removed usages of Thread.sleep

[orpiske]

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

commit da72108cc0b5ee56f091b45ba9e621ffa8376643
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Fri Jun 3 14:28:09 2022 +0200

    (chores) camel-ignite removed usages of Thread.sleep
---
 .../java/org/apache/camel/component/ignite/IgniteEventsTest.java  | 8 +++++---
 .../org/apache/camel/component/ignite/IgniteMessagingTest.java    | 6 ++++--
 2 files changed, 9 insertions(+), 5 deletions(-)

diff --git 
a/components/camel-ignite/src/test/java/org/apache/camel/component/ignite/IgniteEventsTest.java
 
b/components/camel-ignite/src/test/java/org/apache/camel/component/ignite/IgniteEventsTest.java
index b1b8a046dee..b5c55d0a224 100644
--- 
a/components/camel-ignite/src/test/java/org/apache/camel/component/ignite/IgniteEventsTest.java
+++ 
b/components/camel-ignite/src/test/java/org/apache/camel/component/ignite/IgniteEventsTest.java
@@ -34,10 +34,13 @@ import org.apache.ignite.configuration.IgniteConfiguration;
 import org.apache.ignite.events.Event;
 import org.apache.ignite.events.EventType;
 import org.assertj.core.api.Assertions;
+import org.hamcrest.Matchers;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.TestInstance;
 
+import static org.awaitility.Awaitility.await;
+
 @TestInstance(TestInstance.Lifecycle.PER_CLASS)
 public class IgniteEventsTest extends AbstractIgniteTest {
 
@@ -71,9 +74,8 @@ public class IgniteEventsTest extends AbstractIgniteTest {
         cache.withExpiryPolicy(CreatedExpiryPolicy.factoryOf(new 
Duration(TimeUnit.MILLISECONDS, 100)).create())
                 .put(resourceUid, "123");
 
-        Thread.sleep(150);
-
-        cache.get(resourceUid);
+        await().atMost(150, TimeUnit.MILLISECONDS)
+                .until(() -> cache.get(resourceUid), Matchers.nullValue());
 
         assertMockEndpointsSatisfied();
 
diff --git 
a/components/camel-ignite/src/test/java/org/apache/camel/component/ignite/IgniteMessagingTest.java
 
b/components/camel-ignite/src/test/java/org/apache/camel/component/ignite/IgniteMessagingTest.java
index 60750d13545..0817b78cded 100644
--- 
a/components/camel-ignite/src/test/java/org/apache/camel/component/ignite/IgniteMessagingTest.java
+++ 
b/components/camel-ignite/src/test/java/org/apache/camel/component/ignite/IgniteMessagingTest.java
@@ -32,6 +32,7 @@ import org.apache.camel.Processor;
 import org.apache.camel.component.ignite.messaging.IgniteMessagingComponent;
 import org.apache.ignite.lang.IgniteBiPredicate;
 import org.assertj.core.api.Assertions;
+import org.hamcrest.Matchers;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.TestInstance;
@@ -78,8 +79,9 @@ public class IgniteMessagingTest extends AbstractIgniteTest 
implements Serializa
 
         template.requestBodyAndHeader("ignite-messaging:" + TOPIC1, 1, 
IgniteConstants.IGNITE_MESSAGING_TOPIC, "TOPIC2");
 
-        Thread.sleep(1000);
-        Assertions.assertThat(messages1.size()).isEqualTo(0);
+        await().atMost(1, TimeUnit.SECONDS)
+                .until(() -> messages1.size(), Matchers.equalTo(0));
+
         Assertions.assertThat(messages2.size()).isEqualTo(1);
     }