Package javax.jms

Examples of javax.jms.Session.recover()

633
634
635
636
637
638
639
640
641
642
643
               assertNotNull(tm);

               assertEquals("Message:" + j, tm.getText());
            }

            sess2.recover();
         }
        
         //At this point all the messages have been delivered exactly MAX_DELIVERIES times - this is ok
         //they haven't exceeded max delivery attempts so shouldn't be in the DLQ - let's check
        
View Full Code Here
319
320
321
322
323
324
325
326
327
328
329
         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
288
289
290
291
292
293
294
295
296
297
298
        //Send 1
        sendAndCommitMessage(producer,"4");

        //Receive 1 and recover
        received = assertReceiveAndValidateMessage(consumer, "4");
        consumerSession.recover();

        //Receive same 1
        received = assertReceiveAndValidateMessage(consumer, "4");
        received.acknowledge();
View Full Code Here
301
302
303
304
305
306
307
308
309
310
311
        sendAndCommitMessage(producer,"6");
        sendAndCommitMessage(producer,"5");

        //Receive 1 of 3 (possibly out of order due to pre-fetch)
        final Message messageBeforeRollback = assertReceiveMessage(consumer);
        consumerSession.recover();

        if (isBroker010())
        {
            //Receive 3 in sorted order (not as per JMS recover)
            received = assertReceiveAndValidateMessage(consumer, "5");
View Full Code Here
426
427
428
429
430
431
432
433
434
435
436
                    else if(_sessionType == Session.CLIENT_ACKNOWLEDGE)
                    {
                         if (_count%10 == 0)
                         {
                             LOGGER.debug("client ack session recover");
                             session.recover();
                         }
                         else
                         {
                             LOGGER.debug("client ack session acknowledge");
                             msg.acknowledge();
View Full Code Here
339
340
341
342
343
344
345
346
347
348
349
 
      log.trace("Received " + count +  " messages");
 
      assertEquals(count, NUM_MESSAGES);
 
      consumerSess.recover();
       
        assertRemainingMessages(NUM_MESSAGES);
 
      log.trace("Session recover called");
 
View Full Code Here
426
427
428
429
430
431
432
433
434
435
436
           assertRemainingMessages(NUM_MESSAGES - (i + 1));
      }
 
        assertRemainingMessages(0);
        
      consumerSess.recover();
     
      Message m = consumer.receive(200);
      assertNull(m);
    }
    finally
View Full Code Here
495
496
497
498
499
500
501
502
503
504
505
 
      log.trace("Received " + count +  " messages");
 
      assertEquals(count, NUM_MESSAGES);
 
      consumerSess.recover();
 
      log.trace("Session recover called");
 
      m = consumer.receive(200);
 
View Full Code Here
574
575
576
577
578
579
580
581
582
583
584
 
      log.trace("Received " + count +  " messages");
 
      assertEquals(count, NUM_MESSAGES);
 
      consumerSess.recover();
 
      log.trace("Session recover called");
 
      count = 0;
      while (true)
View Full Code Here
657
658
659
660
661
662
663
664
665
666
667
 
      log.trace("Received " + count +  " messages");
 
      assertEquals(count, NUM_MESSAGES);
 
      consumerSess.recover();
 
      log.trace("Session recover called");
 
      m = consumer.receive(2000);
 
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.