Skip to content

Commit 44b689a

Browse files
author
Simon MacMullen
committed
Add a checkShutdownSignal(). I don't think it's legitimate to throw AlreadyClosedException here, so remove that.
1 parent 3f04006 commit 44b689a

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -248,8 +248,9 @@ public void testUnknownTagAck()
248248
txCommit();
249249
fail("expected exception");
250250
}
251-
catch (IOException e) {}
252-
catch (AlreadyClosedException e) {}
251+
catch (IOException e) {
252+
checkShutdownSignal(AMQP.NOT_FOUND, e);
253+
}
253254
connection = null;
254255
openConnection();
255256
}

0 commit comments

Comments
 (0)