You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ta...@apache.org on 2023/07/24 22:00:22 UTC
[qpid-protonj2] branch main updated: PROTON-2749 Fix intermittent failures introduced in previous change
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 369d9bbb PROTON-2749 Fix intermittent failures introduced in previous change
369d9bbb is described below
commit 369d9bbbc4b8e62a3437cd5f50ff5bcd78c811e8
Author: Timothy Bish <ta...@gmail.com>
AuthorDate: Mon Jul 24 18:00:09 2023 -0400
PROTON-2749 Fix intermittent failures introduced in previous change
ensure header frames are properly added to expects script
---
.../src/main/java/org/apache/qpid/protonj2/test/driver/ScriptWriter.java | 1 +
.../java/org/apache/qpid/protonj2/test/driver/ProtonTestServerTest.java | 1 +
2 files changed, 2 insertions(+)
diff --git a/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/ScriptWriter.java b/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/ScriptWriter.java
index 494fd08d..1138d8f3 100644
--- a/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/ScriptWriter.java
+++ b/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/ScriptWriter.java
@@ -585,6 +585,7 @@ public abstract class ScriptWriter {
remoteSaslInit().withMechanism("ANONYMOUS").queue();
expectSaslOutcome().withCode(SaslCode.OK);
remoteAMQPHeader().queue();
+ expectAMQPHeader();
// This trigger the exchange of frames.
remoteSASLHeader().now();
diff --git a/protonj2-test-driver/src/test/java/org/apache/qpid/protonj2/test/driver/ProtonTestServerTest.java b/protonj2-test-driver/src/test/java/org/apache/qpid/protonj2/test/driver/ProtonTestServerTest.java
index 21f2c812..659db896 100644
--- a/protonj2-test-driver/src/test/java/org/apache/qpid/protonj2/test/driver/ProtonTestServerTest.java
+++ b/protonj2-test-driver/src/test/java/org/apache/qpid/protonj2/test/driver/ProtonTestServerTest.java
@@ -111,6 +111,7 @@ public class ProtonTestServerTest extends TestPeerTestsBase {
client.remoteSaslInit().withMechanism("PLAIN").withInitialResponse(peer.saslPlainInitialResponse("user", "pass")).queue();
client.expectSaslOutcome().withCode(SaslCode.OK);
client.remoteHeader(AMQPHeader.getAMQPHeader()).queue();
+ client.expectAMQPHeader();
// Start the exchange with the client SASL header
client.remoteHeader(AMQPHeader.getSASLHeader()).now();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org