38663867386838693870387138723873387438753876
queue.handle(observer, ref, tx); // no messages in the channel yet assertEquals(0, queue.browse().size()); tx.commit(); List stored = queue.browse(); assertEquals(1, stored.size()); Message sm = (Message)stored.iterator().next();
39093910391139123913391439153916391739183919
} // no messages in the channel yet assertEquals(0, queue.browse().size()); tx.commit(); assertEqualSets(refs, queue.browse()); } /**
39473948394939503951395239533954395539563957
} // no messages in the channel yet assertEquals(0, queue.browse().size()); tx.commit(); assertEqualSets(refs, queue.browse()); }
43394340434143424343434443454346434743484349
assertEquals(0, queue.browse().size()); // no message at the receiver assertTrue(r.getMessages().isEmpty()); tx.commit(); assertTrue(queue.browse().isEmpty()); List received = r.getMessages(); assertEquals(1, received.size());
43874388438943904391439243934394439543964397
queue.handle(observer, ref, tx); // no messages in the channel assertEquals(0, queue.browse().size()); tx.commit(); assertEquals(2, queue.browse().size()); assertEquals(1, brokenReceiver.getMessages().size()); }
44304431443244334434443544364437443844394440
assertEquals(0, queue.browse().size()); // no message at the receiver assertTrue(r.getMessages().isEmpty()); tx.commit(); assertTrue(queue.browse().isEmpty()); assertEqualSets(refs, r.getMessages()); }
44724473447444754476447744784479448044814482
assertEquals(0, queue.browse().size()); // no message at the receiver assertTrue(r.getMessages().isEmpty()); tx.commit(); // no messages in the channel assertEquals(0, queue.browse().size()); List received = r.getMessages();
45214522452345244525452645274528452945304531
assertEquals(0, queue.browse().size()); // no message at the receiver assertTrue(r.getMessages().isEmpty()); tx.commit(); // no messages in the channel assertEquals(0, queue.browse().size()); assertEqualSets(refs, r.getMessages());
45674568456945704571457245734574457545764577
49494950495149524953495449554956495749584959
r.acknowledge(ackm, tx); deliveringCount = queue.getDeliveringCount(); assertEquals(1, deliveringCount); tx.commit(); assertTrue(queue.browse().isEmpty()); }