Connection connection = pds.getConnection();
PooledConnectionProxy handle = (PooledConnectionProxy) connection;
XAResource xaResource = handle.getPooledConnection().getXAResource();
connection.close();
assertEquals(0, xaResource.recover(XAResource.TMSTARTRSCAN | XAResource.TMENDRSCAN).length);
assertEquals(0, TransactionManagerServices.getJournal().collectDanglingRecords().size());
pds.close();
TransactionManagerServices.getTransactionManager().shutdown();