Examples of javax.jms.Session.recover()

javax.jms.Session.recover()

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

View Full Code Here

         if (_log.isTraceEnabled())
         {
            _log.trace("Recover session " + this);
         }


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

View Full Code Here


        prod.send(sentMessage);
        Message receivedMessage = consForTopic1.receive(1000);
        assertNotNull("message should be received by consumer", receivedMessage);


        jmsSession.recover();
        receivedMessage = consForTopic1.receive(1000);
        assertNotNull("message should be re-received by consumer after recover", receivedMessage);
        receivedMessage.acknowledge();
    }

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


         log.trace("Received " + count + " messages");


         ProxyAssertSupport.assertEquals(count, NUM_MESSAGES);


         consumerSess.recover();


         assertRemainingMessages(NUM_MESSAGES);


         log.trace("Session recover called");

View Full Code Here

            assertRemainingMessages(NUM_MESSAGES - (i + 1));
         }


         assertRemainingMessages(0);


         consumerSess.recover();


         Message m = consumer.receive(200);
         ProxyAssertSupport.assertNull(m);
      }
      finally

View Full Code Here


         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

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.