Examples of javax.jms.QueueSession.rollback()

javax.jms.QueueSession.rollback()

               {
                  sender.send(message, persistence, 4, 0);
               }


               if (explicit)
                  session.rollback();
               session.close();
            }
            catch (Exception e)
            {
               log.error("error", e);

View Full Code Here

            listener.wait();
      }
      receiver.setMessageListener(null);


      if (explicit)
         session.rollback();
      session.close();


      queueConnection.stop();


      sendThread.join();

View Full Code Here


         TextMessage mr = (TextMessage)cons.receive(3000);
         assertNotNull(mr);
         assertEquals("testing1", mr.getText());


         sess.rollback();


         mr = (TextMessage)cons.receive(3000);
         assertNotNull(mr);
         assertEquals("testing1", mr.getText());

View Full Code Here

                    sleep(100);
                }
                /* Wait 3 seconds, give the provider a bit of time ... */
                sleep(3000);
                /* Discard messages sent */
                qs.rollback();
                /* Wait 3 seconds, give the provider a bit of time ... */
                Thread.sleep(3000);
                /* Resend the messages */
                for(int i = 0; i < num; i++) {
                    qsender.send(msgs[i]);

View Full Code Here

                Assert.assertTrue(i + ":redelivered", !omsg.getJMSRedelivered());
            }
            Message msg = qr.receiveNoWait();
            Assert.assertNull("null-message", msg);
            /* rollback session and receive message again */
            s_rec.rollback();
            /* AGAIN:Receive the 5 messages in the queue */
            for(int i = 0; i < num; i++) {
                ObjectMessage omsg = (ObjectMessage)qr.receiveNoWait();
                Assert.assertNotNull(i + ":message-redeliver", omsg);
                Integer I = (Integer)omsg.getObject();

View Full Code Here

                Assert.assertEquals("Integer-Value", i, I.intValue());
                Assert.assertTrue(i + ":redelivered", !omsg.getJMSRedelivered());
            }
            /* rollback session and receive message again */
            ml.clearMessagesReceived();
            s_rec.rollback();
            /* AGAIN:Receive the messages in the queue */
            /* give the provider a bit of time to deliver the messages */
            Thread.sleep(3000);
            Assert.assertEquals("No of messages received", num, ml.noOfMessagesReceived());
            /* Check the content of the messages */

View Full Code Here

               {
                  sender.send(message, persistence, 4, 0);
               }


               if (explicit)
                  session.rollback();
               session.close();
            }
            catch (Exception e)
            {
               log.error("error", e);

View Full Code Here

            listener.wait();
      }
      receiver.setMessageListener(null);


      if (explicit)
         session.rollback();
      session.close();


      queueConnection.stop();


      sendThread.join();

View Full Code Here


         TextMessage mr = (TextMessage)cons.receive(3000);
         assertNotNull(mr);
         assertEquals("testing1", mr.getText());


         sess.rollback();


         mr = (TextMessage)cons.receive(3000);
         assertNotNull(mr);
         assertEquals("testing1", mr.getText());

View Full Code Here

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.