Examples of javax.jms.Session.recover()

javax.jms.Session.recover()

  
      log.trace("Received " + count +  " messages");
  
      assertEquals(count, NUM_MESSAGES);
  
      consumerSess.recover();
  
      log.trace("Session recover called");
  
      m = consumer.receive(200);

View Full Code Here


         assertNotNull(messageReceived);


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


         session.recover();


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


         assertEquals("two", messageReceived.getText());

View Full Code Here

         if (HornetQRASession.trace)
         {
            HornetQRASession.log.trace("Recover session " + this);
         }


         session.recover();
      }
      finally
      {
         unlock();
      }

View Full Code Here

         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

         cons1.close();


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


         // redeliver
         sess.recover();


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


         log.debug("receiving ...");

View Full Code Here

         ProxyAssertSupport.assertEquals("xoxo", tm.getText());
         ProxyAssertSupport.assertTrue("JMSXDeliveryCount is supposed to exist as a property",
                                       tm.propertyExists("JMSXDeliveryCount"));
         ProxyAssertSupport.assertEquals(1, tm.getIntProperty("JMSXDeliveryCount"));


         s.recover();


         tm = (TextMessage)c.receive(1000);


         ProxyAssertSupport.assertEquals("xoxo", tm.getText());
         ProxyAssertSupport.assertTrue("JMSXDeliveryCount is supposed to exist as a property",

View Full Code Here

                                             tm.propertyExists("JMSXDeliveryCount"));
               ProxyAssertSupport.assertEquals(j + 1, tm.getIntProperty("JMSXDeliveryCount"));
            }
            if (j != NUM_RECOVERIES - 1)
            {
               sess2.recover();
            }
         }


         tm.acknowledge();
      }

View Full Code Here


         ProxyAssertSupport.assertEquals(1, rm.getIntProperty("JMSXDeliveryCount"));


         ProxyAssertSupport.assertFalse(rm.getJMSRedelivered());


         consumerSess.recover();


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


         ProxyAssertSupport.assertNotNull(rm);

View Full Code Here


         ProxyAssertSupport.assertEquals(2, rm.getIntProperty("JMSXDeliveryCount"));


         ProxyAssertSupport.assertTrue(rm.getJMSRedelivered());


         consumerSess.recover();


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


         ProxyAssertSupport.assertNotNull(rm);

View Full Code Here

                {
                    session.rollback();
                }
                else if (session.getAcknowledgeMode() == Session.CLIENT_ACKNOWLEDGE)
                {
                    session.recover();
                }
            }
        }
        catch (final JMSException jmse)
        {

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.