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
