Although basic.ack is async, the channel could have already closed before we get to the txCommit(). There are several similar looking try/catch blocks in this class, but they all check the expression inside the try fails, not the expression immediately before it.

Author: Simon MacMullen

test/src/com/rabbitmq/client/test/functional/TransactionsBase.java

@@ -18,6 +18,7 @@
 package com.rabbitmq.client.test.functional;
 
 import com.rabbitmq.client.AMQP;
+import com.rabbitmq.client.AlreadyClosedException;
 import com.rabbitmq.client.test.BrokerTestCase;
 import java.io.IOException;
 
@@ -236,6 +237,9 @@ public void testUnknownTagAck()
         catch (IOException e) {
             checkShutdownSignal(AMQP.PRECONDITION_FAILED, e);
         }
+        catch (AlreadyClosedException e) {
+            checkShutdownSignal(AMQP.PRECONDITION_FAILED, e);
+        }
         connection = null;
         openConnection();
     }