Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #444

This commit is contained in:
Clebert Suconic 2016-04-08 10:07:09 -04:00
parent 6bbceff7c0 9055c76cc8
commit 5bcf5cbe17
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/SessionCloseTest.java
View File

@ -144,10 +144,17 @@ public class SessionCloseTest extends ActiveMQTestBase {
Assert.assertTrue(session.isXA()); Assert.assertTrue(session.isXA());
Assert.assertTrue(session.isClosed()); Assert.assertTrue(session.isClosed());
ActiveMQTestBase.expectXAException(XAException.XAER_RMFAIL, new ActiveMQAction() {
@Override
public void run() throws XAException {
session.commit(randomXid(), true);
}
});
ActiveMQTestBase.expectXAException(XAException.XA_RETRY, new ActiveMQAction() { ActiveMQTestBase.expectXAException(XAException.XA_RETRY, new ActiveMQAction() {
@Override @Override
public void run() throws XAException { public void run() throws XAException {
session.commit(randomXid(), RandomUtil.randomBoolean()); session.commit(randomXid(), false);
} }
}); });