690691692693694695696697698699700
} // no messages in the channel yet assertEquals(0, queue.browse(null).size()); tx.commit(); assertEqualSets(refs, queue.browse(null)); }
729730731732733734735736737738739
} // no messages in the channel yet assertEquals(0, queue.browse(null).size()); tx.commit(); assertEqualSets(refs, queue.browse(null)); } /**
766767768769770771772773774775776
11581159116011611162116311641165116611671168
assertEquals(0, queue.browse(null).size()); // no message at the receiver assertTrue(r.getMessages().isEmpty()); tx.commit(); assertTrue(queue.browse(null).isEmpty()); List received = r.getMessages(); assertEquals(1, received.size());
12051206120712081209121012111212121312141215
assertEquals(0, queue.browse(null).size()); // no message at the receiver assertTrue(r.getMessages().isEmpty()); tx.commit(); assertTrue(queue.browse(null).isEmpty()); assertEqualSets(refs, r.getMessages()); }
12531254125512561257125812591260126112621263
assertEquals(0, queue.browse(null).size()); // no message at the receiver assertTrue(r.getMessages().isEmpty()); tx.commit(); // no messages in the channel assertEquals(0, queue.browse(null).size()); List received = r.getMessages();
13081309131013111312131313141315131613171318
assertEquals(0, queue.browse(null).size()); // no message at the receiver assertTrue(r.getMessages().isEmpty()); tx.commit(); // messages at the receiver assertEqualSets(refs, r.getMessages()); }
13501351135213531354135513561357135813591360
assertEquals(0, queue.browse(null).size()); // no message at the receiver assertTrue(r.getMessages().isEmpty()); tx.commit(); // no messages in the channel assertEquals(0, queue.browse(null).size()); assertEqualSets(refs, r.getMessages());
242243244245246247248249250251252
if (tx) { if (xa) { theTx.prepare(); theTx.commit(); } else { theTx.commit(); }
246247248249250251252253254255256
theTx.prepare(); theTx.commit(); } else { theTx.commit(); } } } }