Examples of javax.jms.Session.rollback()

javax.jms.Session.rollback()

    msg = prodSession.createTextMessage("Message2");
    producer.send(queue1, msg);
    
    msg = (TextMessage) consumer.receive();
    System.out.println("Receives: " + msg.getText() + " then deny it!");
    consSession.rollback();
    
    msg = (TextMessage) consumer.receive();
    System.out.println("Receives: " + msg.getText() + " then deny it!");
    consSession.rollback();

View Full Code Here

    System.out.println("Receives: " + msg.getText() + " then deny it!");
    consSession.rollback();
    
    msg = (TextMessage) consumer.receive();
    System.out.println("Receives: " + msg.getText() + " then deny it!");
    consSession.rollback();
        
    // Producing "forbidden" messages
    System.out.println("Send Message3");   
    msg = prodSession.createTextMessage("Message3");
    try {

View Full Code Here

      mRec = (TextMessage)consumer.receive();
      log.trace("Received 2");
      assertNotNull(mRec);
      assertEquals("rollback", mRec.getText());
            
      sess.rollback();
      
      TextMessage mRec2 = (TextMessage)consumer.receive();
      assertNotNull(mRec2);
      assertEquals("rollback", mRec2.getText());

View Full Code Here

         Session producerSess = conn.createSession(false, Session.CLIENT_ACKNOWLEDGE);
   
         boolean thrown = false;
         try
         {
            producerSess.rollback();
         }
         catch (javax.jms.IllegalStateException e)
         {
            thrown = true;
         }

View Full Code Here

            count++;
         }
   
         assertEquals(NUM_MESSAGES, count);
   
         consumerSess.rollback();
   
         conn.stop();
         consumer.close();
   
         conn.close();

View Full Code Here

               }
               else
               {
                  lastCount = messageCount;
                  log.debug("rollback");
                  session.rollback();
               }


               messageCount++;


               if (messageCount %7 == 0)

View Full Code Here

                  }
                  else
                  {
                     log.debug("rollback");
                     lastMessage = messageCount;
                     sess.rollback();
                  }
                  messageCount ++;


               }

View Full Code Here


      assertEquals("one", ((TextMessage)m).getText());
      assertFalse(m.getJMSRedelivered());
      assertEquals(1, m.getIntProperty("JMSXDeliveryCount"));


      s.rollback();


      // get the message again
      m = c.receive();
      assertTrue(m.getJMSRedelivered());
      assertEquals(2, m.getIntProperty("JMSXDeliveryCount"));

View Full Code Here

              
         TextMessage mRec1 = (TextMessage)consumer1.receive(2000);
         assertEquals("igloo", mRec1.getText());
         assertFalse(mRec1.getJMSRedelivered());
         
         sess1.rollback(); //causes redelivery for session


         mRec1 = (TextMessage)consumer1.receive(2000);
         assertEquals("igloo", mRec1.getText());
         assertTrue(mRec1.getJMSRedelivered());

View Full Code Here

         TextMessage mRec = (TextMessage)consumer.receive(2000);


         assertEquals("igloo", mRec.getText());
         assertFalse(mRec.getJMSRedelivered());
         
         sess.rollback();


         mRec = (TextMessage)consumer.receive(2000);


         assertNotNull(mRec);
         assertEquals("igloo", mRec.getText());

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.