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 241c842 Add additional waits for the intermediate peer to complete
241c842 is described below
commit 241c84228343cf7ebd541fe5e7684818e4f3dc15
Author: Timothy Bish <[email protected]>
AuthorDate: Tue Apr 27 19:08:49 2021 -0400
Add additional waits for the intermediate peer to complete
If not waiting for the intermediate peer the test can get ahead of the
expected flow and send an unexpected frame.
---
.../org/apache/qpid/protonj2/client/impl/ReconnectSenderTest.java | 1 +
.../org/apache/qpid/protonj2/client/impl/ReconnectSessionTest.java | 4 +++-
2 files changed, 4 insertions(+), 1 deletion(-)
diff --git
a/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/ReconnectSenderTest.java
b/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/ReconnectSenderTest.java
index 6c37c3b..8b6f9a3 100644
---
a/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/ReconnectSenderTest.java
+++
b/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/ReconnectSenderTest.java
@@ -340,6 +340,7 @@ class ReconnectSenderTest extends ImperativeClientTestCase {
Sender sender2 = session.openSender("queue-2");
firstPeer.waitForScriptToComplete();
+ intermediatePeer.waitForScriptToComplete();
// Await both being open before doing work to make the outcome
predictable
sender1.openFuture().get();
diff --git
a/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/ReconnectSessionTest.java
b/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/ReconnectSessionTest.java
index 31577b0..64a471d 100644
---
a/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/ReconnectSessionTest.java
+++
b/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/ReconnectSessionTest.java
@@ -27,6 +27,7 @@ import org.apache.qpid.protonj2.client.Receiver;
import org.apache.qpid.protonj2.client.Session;
import org.apache.qpid.protonj2.client.test.ImperativeClientTestCase;
import org.apache.qpid.protonj2.test.driver.ProtonTestServer;
+import org.junit.jupiter.api.RepeatedTest;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.Timeout;
@@ -120,7 +121,7 @@ class ReconnectSessionTest extends ImperativeClientTestCase
{
}
}
- @Test
+ @RepeatedTest(10)
public void
testMultipleSessionCreationRecoversAfterDropWithNoBeginResponse() throws
Exception {
try (ProtonTestServer firstPeer = new ProtonTestServer();
ProtonTestServer intermediatePeer = new ProtonTestServer();
@@ -166,6 +167,7 @@ class ReconnectSessionTest extends ImperativeClientTestCase
{
Session session2 = connection.openSession();
firstPeer.waitForScriptToComplete();
+ intermediatePeer.waitForScriptToComplete();
// Await both being open before doing work to make the outcome
predictable
session1.openFuture().get();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
