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 19e48d4fa31e67fd8a70746f081906b39083d959 Author: Timothy Bish <[email protected]> AuthorDate: Tue Jul 11 15:55:54 2023 -0400 PROTON-2750 Ensure the frame parser is ready for AMQP header on connect Always reset the frame parser to expect AMQP headers on a new connection --- .../main/java/org/apache/qpid/protonj2/test/driver/AMQPTestDriver.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/AMQPTestDriver.java b/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/AMQPTestDriver.java index a13d9c3a..7bbd2b88 100644 --- a/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/AMQPTestDriver.java +++ b/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/AMQPTestDriver.java @@ -248,10 +248,13 @@ public class AMQPTestDriver implements Consumer<ByteBuffer> { void handleConnectedEstablished() throws AssertionError { synchronized (script) { + // Any new AMQP connection starts with the header so we reset the parser + // to begin a new exchange. ScriptedElement peekNext = script.peek(); if (peekNext instanceof ScriptedAction) { processScript(peekNext); } + resetToExpectingAMQPHeader(); } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
