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
commit bc91bc96296e450e4f8bee3446d0b6fbd0b257e1
Author: Timothy Bish <tabish...@gmail.com>
AuthorDate: Tue May 4 13:21:09 2021 -0400
Fix an intermittent test failure spotted in CI
---
.../java/org/apache/qpid/protonj2/client/impl/StreamSenderTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 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 9a12b51..9d523a2 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
@@ -2415,7 +2415,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();
@@ -2456,7 +2456,7 @@ public class StreamSenderTest extends
ImperativeClientTestCase {
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).now();
stream.close();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
