10221023102410251026102710281029103010311032
TextMessage rm1 = (TextMessage)cons1.receive(1500); assertNotNull(rm1); assertEquals("hello1", rm1.getText()); //redeliver sess.recover(); TextMessage rm2 = (TextMessage)cons1.receive(1500); assertNotNull(rm2); assertEquals("hello1", rm2.getText());
10821083108410851086108710881089109010911092
Thread.sleep(500); log.debug("sess.recover()"); //redeliver sess.recover(); MessageConsumer cons2 = sess.createConsumer(queue); log.debug("receiving ...");
388389390391392393394395396397398
log.trace("Received " + count + " messages"); assertEquals(count, NUM_MESSAGES); consumerSess.recover(); assertRemainingMessages(NUM_MESSAGES); log.trace("Session recover called");
485486487488489490491492493494495
assertNull(m); log.trace("mesage is " + m); log.trace("calling session recover()"); consumerSess.recover(); log.trace("recover called"); m = consumer.receive(200); assertNull(m);
546547548549550551552553554555556
log.trace("Received " + count + " messages"); assertEquals(count, NUM_MESSAGES); consumerSess.recover(); log.trace("Session recover called"); m = consumer.receive(200);
616617618619620621622623624625626
log.trace("Received " + count + " messages"); assertEquals(count, NUM_MESSAGES); consumerSess.recover(); log.trace("Session recover called"); count = 0; while (true)
688689690691692693694695696697698
845846847848849850851852853854855
235236237238239240241242243244245
assertNotNull(tm); assertEquals("Message:" + j, tm.getText()); } sess2.recover(); } //At this point all the messages have been delivered exactly MAX_DELIVERIES times Message m = cons.receive(1000);
296297298299300301302303304305306