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 2022/06/15 12:51:43 UTC

[camel] 04/05: (chores) camel-mina: remove unnecessary calls to Thread.sleep

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 c78617e157941327c46c935dc54ca4fd11d0de96
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Wed Jun 15 11:09:50 2022 +0200

    (chores) camel-mina: remove unnecessary calls to Thread.sleep
---
 .../apache/camel/component/mina/MinaSslContextParametersUdpTest.java    | 1 -
 .../java/org/apache/camel/component/mina/MinaUdpConcurrentTest.java     | 1 -
 .../src/test/java/org/apache/camel/component/mina/MinaUdpTest.java      | 1 -
 .../camel/component/mina/MinaUdpWithInOutUsingPlainSocketTest.java      | 2 --
 4 files changed, 5 deletions(-)

diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaSslContextParametersUdpTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaSslContextParametersUdpTest.java
index b6de8d1fece..d4c747b8c8d 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaSslContextParametersUdpTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaSslContextParametersUdpTest.java
@@ -52,7 +52,6 @@ public class MinaSslContextParametersUdpTest extends BaseMinaTest {
                 DatagramPacket packet = new DatagramPacket(data, data.length, address, getPort());
                 socket.send(packet);
             }
-            Thread.sleep(2000);
         } finally {
             socket.close();
         }
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpConcurrentTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpConcurrentTest.java
index 4e9db536b7f..1b1f9bc071a 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpConcurrentTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpConcurrentTest.java
@@ -52,7 +52,6 @@ public class MinaUdpConcurrentTest extends BaseMinaTest {
                 DatagramPacket packet = new DatagramPacket(data, data.length, address, getPort());
                 socket.send(packet);
             }
-            Thread.sleep(2000);
         } finally {
             socket.close();
         }
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpTest.java
index 9a19829160f..d0fa6446807 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpTest.java
@@ -52,7 +52,6 @@ public class MinaUdpTest extends BaseMinaTest {
                 DatagramPacket packet = new DatagramPacket(data, data.length, address, getPort());
                 socket.send(packet);
             }
-            Thread.sleep(2000);
         } finally {
             socket.close();
         }
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpWithInOutUsingPlainSocketTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpWithInOutUsingPlainSocketTest.java
index b48f8b21fd5..043ec312aee 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpWithInOutUsingPlainSocketTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpWithInOutUsingPlainSocketTest.java
@@ -52,8 +52,6 @@ public class MinaUdpWithInOutUsingPlainSocketTest extends BaseMinaTest {
         LOG.debug("+++ Sending data +++");
         socket.send(packet);
 
-        Thread.sleep(1000);
-
         byte[] buf = new byte[128];
         DatagramPacket receive = new DatagramPacket(buf, buf.length, address, getPort());
         LOG.debug("+++ Receiveing data +++");