We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 23a9a58 commit ffb7cd6Copy full SHA for ffb7cd6
test/src/com/rabbitmq/client/test/functional/TransactionsBase.java
@@ -230,16 +230,9 @@ public void testUnknownTagAck()
230
basicGet();
231
basicAck();
232
basicAck(latestTag+1, true);
233
- try {
234
- txCommit();
235
- fail("expected exception");
236
- }
237
- catch (IOException e) {
238
- checkShutdownSignal(AMQP.PRECONDITION_FAILED, e);
239
240
- catch (AlreadyClosedException e) {
241
242
+ // "On a transacted channel, this check MUST be done immediately and
+ // not delayed until a Tx.Commit."
+ expectError(AMQP.PRECONDITION_FAILED);
243
connection = null;
244
openConnection();
245
}
0 commit comments