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 aec62289 NO-JIRA Extend some test timeouts and waits for slower CI jobs
aec62289 is described below
commit aec6228933e4ff2427a2a5110b7dd80f3c24a812
Author: Timothy Bish <[email protected]>
AuthorDate: Fri Sep 20 13:04:29 2024 -0400
NO-JIRA Extend some test timeouts and waits for slower CI jobs
Attempt to stabilize some tests on slower CI runs where open timeouts
can trigger to quickly.
---
.../org/apache/qpid/protonj2/client/impl/SenderTest.java | 14 +++-----------
1 file changed, 3 insertions(+), 11 deletions(-)
diff --git
a/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/SenderTest.java
b/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/SenderTest.java
index 4f097bf1..78fd08e9 100644
---
a/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/SenderTest.java
+++
b/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/SenderTest.java
@@ -1315,7 +1315,7 @@ public class SenderTest extends ImperativeClientTestCase {
Session session = connection.openSession();
session.openFuture().get();
- SenderOptions options = new SenderOptions().openTimeout(75);
+ SenderOptions options = new SenderOptions().openTimeout(100);
Sender sender = session.openSender("test-sender", options);
peer.waitForScriptToComplete(5, TimeUnit.SECONDS);
@@ -1381,13 +1381,9 @@ public class SenderTest extends ImperativeClientTestCase
{
LOG.info("Connect test started, peer listening on: {}", remoteURI);
Client container = Client.create();
- ConnectionOptions options = new
ConnectionOptions().openTimeout(75);
+ ConnectionOptions options = new
ConnectionOptions().openTimeout(100);
Connection connection = container.connect(remoteURI.getHost(),
remoteURI.getPort(), options);
- connection.openFuture().get();
-
Session session = connection.openSession();
- session.openFuture().get();
-
Sender sender = session.openSender("test-sender");
peer.waitForScriptToComplete(5, TimeUnit.SECONDS);
@@ -1449,13 +1445,9 @@ public class SenderTest extends ImperativeClientTestCase
{
LOG.info("Connect test started, peer listening on: {}", remoteURI);
Client container = Client.create();
- ConnectionOptions options = new
ConnectionOptions().openTimeout(75);
+ ConnectionOptions options = new
ConnectionOptions().openTimeout(100);
Connection connection = container.connect(remoteURI.getHost(),
remoteURI.getPort(), options);
- connection.openFuture().get();
-
Session session = connection.openSession();
- session.openFuture().get();
-
Sender sender = session.openSender("test-sender");
peer.waitForScriptToComplete(5, TimeUnit.SECONDS);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
