14441445144614471448144914501451145214531454
// no message at the receiver assertTrue(r.getMessages().isEmpty()); tx.rollback(); // no messages in the channel assertEquals(0, queue.browse(null).size()); // no message at the receiver
14901491149214931494149514961497149814991500
assertEquals(0, queue.browse(null).size()); // no message at the receiver assertTrue(r.getMessages().isEmpty()); tx.rollback(); // no messages in the channel assertEquals(0, queue.browse(null).size()); // no message at the receiver
15351536153715381539154015411542154315441545
15811582158315841585158615871588158915901591
16271628162916301631163216331634163516361637
18141815181618171818181918201821182218231824
r.acknowledge(ackm, tx); deliveringCount = queue.getDeliveringCount(); assertEquals(1, deliveringCount); tx.rollback(); deliveringCount = queue.getDeliveringCount(); assertEquals(1, deliveringCount); // acknowledge non-transactionally
19521953195419551956195719581959196019611962
Message ackm = (Message)i.next(); // transacted acknowledgment r.acknowledge(ackm, tx); } tx.rollback(); // acknowledge non-transactionally for(Iterator i = r.getMessages().iterator(); i.hasNext();) { Message ackm = (Message)i.next();
24672468246924702471247224732474247524762477
25132514251525162517251825192520252125222523
25582559256025612562256325642565256625672568