This is an automated email from the ASF dual-hosted git repository. tabish pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/qpid-protonj2.git
The following commit(s) were added to refs/heads/main by this push: new bc09785 Adjust some unrealistic timeouts for receive when in CI bc09785 is described below commit bc09785d0618db83fb3b54ad41f894569487e315 Author: Timothy Bish <tabish...@gmail.com> AuthorDate: Fri Apr 23 11:22:50 2021 -0400 Adjust some unrealistic timeouts for receive when in CI Some CI tests can fail due to the overly short receive timeouts where don't give enough time for round trip of the transfer. --- .../org/apache/qpid/protonj2/client/impl/ReceiverTest.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/ReceiverTest.java b/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/ReceiverTest.java index 8a16d88..f23c639 100644 --- a/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/ReceiverTest.java +++ b/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/ReceiverTest.java @@ -1525,7 +1525,7 @@ public class ReceiverTest extends ImperativeClientTestCase { peer.waitForScriptToComplete(5, TimeUnit.SECONDS); - assertNull(receiver.receive(10, TimeUnit.MILLISECONDS)); + assertNull(receiver.receive(15, TimeUnit.MILLISECONDS)); peer.expectDetach().respond(); peer.expectClose().respond(); @@ -1642,7 +1642,7 @@ public class ReceiverTest extends ImperativeClientTestCase { peer.waitForScriptToComplete(5, TimeUnit.SECONDS); - assertNull(receiver.receive(10, TimeUnit.MILLISECONDS)); + assertNull(receiver.receive(15, TimeUnit.MILLISECONDS)); // Credit window is one and next transfer signals aborted so receiver should // top-up the credit window to allow more transfers to arrive. @@ -2185,7 +2185,7 @@ public class ReceiverTest extends ImperativeClientTestCase { peer.expectDetach().respond(); peer.expectClose().respond(); - Delivery delivery = receiver.receive(10, TimeUnit.MILLISECONDS); + Delivery delivery = receiver.receive(5, TimeUnit.SECONDS); assertNotNull(delivery); Message<String> message = delivery.message(); @@ -2287,7 +2287,7 @@ public class ReceiverTest extends ImperativeClientTestCase { peer.expectDetach().respond(); peer.expectClose().respond(); - Delivery delivery = receiver.receive(10, TimeUnit.MILLISECONDS); + Delivery delivery = receiver.receive(5, TimeUnit.SECONDS); assertNotNull(delivery); InputStream stream = delivery.rawInputStream(); assertNotNull(stream); @@ -2354,7 +2354,7 @@ public class ReceiverTest extends ImperativeClientTestCase { peer.expectDetach().respond(); peer.expectClose().respond(); - Delivery delivery = receiver.receive(10, TimeUnit.MILLISECONDS); + Delivery delivery = receiver.receive(5, TimeUnit.SECONDS); assertNotNull(delivery); AdvancedMessage<?> message = delivery.message().toAdvancedMessage(); @@ -2417,7 +2417,7 @@ public class ReceiverTest extends ImperativeClientTestCase { peer.expectDetach().respond(); peer.expectClose().respond(); - Delivery delivery = receiver.receive(10, TimeUnit.MILLISECONDS); + Delivery delivery = receiver.receive(5, TimeUnit.SECONDS); assertNotNull(delivery); InputStream stream = delivery.rawInputStream(); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org