146147148149150151152153154155156
queue2.handle(null, refs2[i], tx); refs2[i].releaseMemoryReference(); } tx.commit(); //Queue1 refIds = getPagedReferenceIds(queue1.getChannelID()); assertEquals(0, refIds.size());
207208209210211212213214215216217
267268269270271272273274275276277
queue2.handle(null, refs2[i], tx); refs2[i].releaseMemoryReference(); } tx.commit(); //Queue1 refIds = getPagedReferenceIds(queue1.getChannelID()); assertEquals(50, refIds.size());
522523524525526527528529530531532
throw new Exception("Test failure before commit"); } if (handleTransactionally) { tx.commit(); } //For testing to simulate failures if (failAfterCommit) {
8687888990919293949596
queue2.handle(null, refs2[i], tx); refs2[i].releaseMemoryReference(); } tx.prepare(); tx.commit(); //Queue1 List refIds = getPagedReferenceIds(queue1.getChannelID()); assertEquals(0, refIds.size());
145146147148149150151152153154155
queue2.handle(null, refs2[i], tx); refs2[i].releaseMemoryReference(); } tx.prepare(); tx.commit(); //Queue1 refIds = getPagedReferenceIds(queue1.getChannelID()); assertEquals(0, refIds.size());
268269270271272273274275276277278
queue2.handle(null, refs2[i], tx); refs2[i].releaseMemoryReference(); } tx.prepare(); tx.commit(); //Queue1 refIds = getPagedReferenceIds(queue1.getChannelID()); assertEquals(50, refIds.size());
134135136137138139140141142143144
assertTrue(msgs.isEmpty()); try { //An exception should be thrown tx.commit(); fail(); } catch (TransactionException e) { //Ok
272273274275276277278279280281282