Package javax.jms

Examples of javax.jms.Session.recover()

557
558
559
560
561
562
563
564
565
566
567
         log.trace("Received " + count + " messages");

         ProxyAssertSupport.assertEquals(count, NUM_MESSAGES);

         consumerSess.recover();

         log.trace("Session recover called");

         count = 0;
         while (true)
View Full Code Here
642
643
644
645
646
647
648
649
650
651
652
         log.trace("Received " + count + " messages");

         ProxyAssertSupport.assertEquals(count, NUM_MESSAGES);

         consumerSess.recover();

         log.trace("Session recover called");

         m = consumer.receive(200);
View Full Code Here
714
715
716
717
718
719
720
721
722
723
724
         log.trace("Received " + count + " messages");

         ProxyAssertSupport.assertEquals(count, NUM_MESSAGES);

         consumerSess.recover();

         log.trace("Session recover called");

         m = consumer.receive(200);
View Full Code Here
843
844
845
846
847
848
849
850
851
852
853
         log.trace("Received " + count + " messages");

         ProxyAssertSupport.assertEquals(count, NUM_MESSAGES);

         consumerSess.recover();

         log.trace("Session recover called");

         m = consumer.receive(200);
View Full Code Here
966
967
968
969
970
971
972
973
974
975
976
         ProxyAssertSupport.assertNotNull(messageReceived);

         ProxyAssertSupport.assertEquals("one", messageReceived.getText());

         session.recover();

         messageReceived = (TextMessage)consumer.receive(1000);

         ProxyAssertSupport.assertEquals("two", messageReceived.getText());
View Full Code Here
1150
1151
1152
1153
1154
1155
1156
1157
1158
1159
1160
         TextMessage rm1 = (TextMessage)cons1.receive(1500);
         ProxyAssertSupport.assertNotNull(rm1);
         ProxyAssertSupport.assertEquals("hello1", rm1.getText());

         // redeliver
         sess.recover();

         TextMessage rm2 = (TextMessage)cons1.receive(1500);
         ProxyAssertSupport.assertNotNull(rm2);
         ProxyAssertSupport.assertEquals("hello1", rm2.getText());
View Full Code Here
1209
1210
1211
1212
1213
1214
1215
1216
1217
1218
1219
         cons1.close();

         log.debug("sess.recover()");

         // redeliver
         sess.recover();

         MessageConsumer cons2 = sess.createConsumer(HornetQServerTestCase.queue1);

         log.debug("receiving ...");
View Full Code Here
459
460
461
462
463
464
465
466
467
468
469
         if (HornetQRASession.trace)
         {
            HornetQRALogger.LOGGER.trace("Recover session " + this);
         }

         session.recover();
      }
      finally
      {
         unlock();
      }
View Full Code Here
309
310
311
312
313
314
315
316
317
318
319
         Session session = getSession();
         if (info.isTransacted())
            throw new IllegalStateException("Session is transacted");
         if (trace)
            log.trace("Recover session " + this);
         session.recover();
      }
      finally
      {
         unlock();
      }
View Full Code Here
292
293
294
295
296
297
298
299
300
301
302
            Session session = getSession();
            if (info.isTransacted())
                throw new IllegalStateException("Session is transacted");
            if (trace)
                log.trace("Recover session " + this);
            session.recover();
        } finally {
            unlock();
        }
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.