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 6e7ce3a PROTON-2507 Test peer fix to actually select a free local
channel
6e7ce3a is described below
commit 6e7ce3aa457cea6631fd8f0d4db94a6bcf47229f
Author: Timothy Bish <[email protected]>
AuthorDate: Thu Feb 24 12:31:22 2022 -0500
PROTON-2507 Test peer fix to actually select a free local channel
---
.../java/org/apache/qpid/protonj2/client/impl/TransactionsTest.java | 2 +-
.../qpid/protonj2/test/driver/expectations/AttachExpectation.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/TransactionsTest.java
b/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/TransactionsTest.java
index 3ad4c97..8534735 100644
---
a/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/TransactionsTest.java
+++
b/protonj2-client/src/test/java/org/apache/qpid/protonj2/client/impl/TransactionsTest.java
@@ -169,7 +169,7 @@ public class TransactionsTest extends
ImperativeClientTestCase {
peer.expectCoordinatorAttach().respond();
peer.remoteFlow().withLinkCredit(2).queue();
peer.expectDeclare();
- peer.expectDetach().respond();
+ peer.expectDetach().respond().afterDelay(5);
peer.start();
URI remoteURI = peer.getServerURI();
diff --git
a/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/expectations/AttachExpectation.java
b/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/expectations/AttachExpectation.java
index 02b1c6b..e18b4e0 100644
---
a/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/expectations/AttachExpectation.java
+++
b/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/expectations/AttachExpectation.java
@@ -128,7 +128,7 @@ public class AttachExpectation extends
AbstractExpectation<Attach> {
// Populate the fields of the response with defaults if non set by
the test script
if (response.getPerformative().getHandle() == null) {
- response.withHandle(attach.getHandle());
+ response.withHandle(session.findFreeLocalHandle());
}
if (response.getPerformative().getName() == null) {
response.withName(attach.getName());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
