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 <tabish...@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-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org