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 71957cc Fix intermittent test failure in CI
71957cc is described below
commit 71957ccd97203c787eac6e9a3748493996d43851
Author: Timothy Bish <[email protected]>
AuthorDate: Wed Apr 28 11:32:57 2021 -0400
Fix intermittent test failure in CI
---
.../apache/qpid/protonj2/client/impl/StreamSenderTest.java | 12 +++++++-----
1 file changed, 7 insertions(+), 5 deletions(-)
diff --git
a/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/StreamSenderTest.java
b/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/StreamSenderTest.java
index 7125a28..9a12b51 100644
---
a/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/StreamSenderTest.java
+++
b/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/StreamSenderTest.java
@@ -2350,7 +2350,7 @@ public class StreamSenderTest extends
ImperativeClientTestCase {
peer.expectOpen().respond();
peer.expectBegin().respond();
peer.expectAttach().ofSender().respond();
-
peer.remoteFlow().withIncomingWindow(WRITE_COUNT).withNextIncomingId(1).withLinkCredit(WRITE_COUNT).queue();
+
peer.remoteFlow().withIncomingWindow(WRITE_COUNT).withNextIncomingId(0).withLinkCredit(WRITE_COUNT).queue();
peer.start();
URI remoteURI = peer.getServerURI();
@@ -2388,15 +2388,17 @@ public class StreamSenderTest extends
ImperativeClientTestCase {
peer.waitForScriptToComplete(5, TimeUnit.SECONDS);
peer.expectTransfer().withNullPayload().withMore(false).accept();
- peer.expectDetach().respond();
- peer.expectEnd().respond();
- peer.expectClose().respond();
// grant one more credit for the complete to arrive.
-
peer.remoteFlow().withIncomingWindow(1).withNextIncomingId(WRITE_COUNT +
1).withLinkCredit(1).now();
+
peer.remoteFlow().withIncomingWindow(1).withNextIncomingId(WRITE_COUNT).withLinkCredit(1).later(10);
stream.close();
+ peer.waitForScriptToComplete(5, TimeUnit.SECONDS);
+ peer.expectDetach().respond();
+ peer.expectEnd().respond();
+ peer.expectClose().respond();
+
sender.closeAsync().get();
connection.closeAsync().get();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
