606607608609610611612613614615616
assertTrue(msg3 == msgRec3); receiver3.acknowledge(msgRec1, null); receiver3.acknowledge(msgRec2, null); receiver3.acknowledge(msgRec3, null); msgs = queue3.browse(); assertNotNull(msgs); assertTrue(msgs.isEmpty()); if (checkNoMessageData()) {
775776777778779780781782783784785
assertNotNull(msgs); assertEquals(1, msgs.size()); msgRec = (Message)msgs.get(0); assertTrue(msg2 == msgRec); receiver6.acknowledge(msgRec, null); msgs = queue6.browse(); assertNotNull(msgs); assertTrue(msgs.isEmpty()); msgs = receiver1.getMessages(); assertNotNull(msgs);
852853854855856857858859860861862
List msgs = queue1.browse(); assertNotNull(msgs); assertTrue(msgs.isEmpty()); msgs = queue2.browse(); assertNotNull(msgs); assertTrue(msgs.isEmpty()); tx.commit();
887888889890891892893894895896897
assertNotNull(msgs); assertTrue(msgs.isEmpty()); receiver1.clear(); msgs = queue2.browse(); assertNotNull(msgs); assertTrue(msgs.isEmpty()); receiver2.clear();
910911912913914915916917918919920
msgs = queue1.browse(); assertNotNull(msgs); assertTrue(msgs.isEmpty()); msgs = queue2.browse(); assertNotNull(msgs); assertTrue(msgs.isEmpty()); tx.rollback();
980981982983984985986987988989990