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 71dddbdd PROTON-2780 Fix potential race on scripted test scenario
71dddbdd is described below

commit 71dddbdde42bc27e34c8ec6a000e2bb362396969
Author: Timothy Bish <tabish...@gmail.com>
AuthorDate: Wed Dec 6 14:20:51 2023 -0500

    PROTON-2780 Fix potential race on scripted test scenario
    
    Fix ordering of test script that can lead to false positive test
    failure.
---
 .../org/apache/qpid/protonj2/test/driver/TransactionHandlingTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/protonj2-test-driver/src/test/java/org/apache/qpid/protonj2/test/driver/TransactionHandlingTest.java
 
b/protonj2-test-driver/src/test/java/org/apache/qpid/protonj2/test/driver/TransactionHandlingTest.java
index 824b5d3f..8c8d2b69 100644
--- 
a/protonj2-test-driver/src/test/java/org/apache/qpid/protonj2/test/driver/TransactionHandlingTest.java
+++ 
b/protonj2-test-driver/src/test/java/org/apache/qpid/protonj2/test/driver/TransactionHandlingTest.java
@@ -196,6 +196,7 @@ class TransactionHandlingTest extends TestPeerTestsBase {
             client.expectOpen();
             client.expectBegin();
             client.expectCoordinatorAttach().ofReceiver();
+            client.expectFlow().withLinkCredit(2);
 
             client.remoteHeader(AMQPHeader.getAMQPHeader()).now();
             client.remoteOpen().now();
@@ -205,7 +206,6 @@ class TransactionHandlingTest extends TestPeerTestsBase {
                                  .withCoordinator().also()
                                  .withSource().withAddress("txn-address")
                                  .and().now();
-            client.expectFlow().withLinkCredit(2);
             client.waitForScriptToComplete(5, TimeUnit.SECONDS);
             client.expectDisposition().withState().declared(new byte[] {0, 1, 
2, 3});
             
client.remoteDeclare().withMessageFormat(messageFormat).withDeliveryTag(new 
byte[] {0}).withDeliveryId(0).now();


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org

Reply via email to