[Jboss-cvs] JBoss Messaging SVN: r1227 - branches/Branch_1_0/tests/src/org/jboss/test/messaging/jms

[jboss-cvs-commits at lists.jboss.org]

Author: ovidiu.feodorov at jboss.com
Date: 2006-08-22 13:18:53 -0400 (Tue, 22 Aug 2006)
New Revision: 1227

Modified:
   branches/Branch_1_0/tests/src/org/jboss/test/messaging/jms/TransactedSessionTest.java
Log:
added a (currently failing) test for http://jira.jboss.org/jira/browse/JBMESSAGING-526

Modified: branches/Branch_1_0/tests/src/org/jboss/test/messaging/jms/TransactedSessionTest.java
===================================================================
--- branches/Branch_1_0/tests/src/org/jboss/test/messaging/jms/TransactedSessionTest.java	2006-08-16 20:25:23 UTC (rev 1226)
+++ branches/Branch_1_0/tests/src/org/jboss/test/messaging/jms/TransactedSessionTest.java	2006-08-22 17:18:53 UTC (rev 1227)
@@ -458,16 +458,11 @@
             conn.close();
          }
       }
-
    }
 
-
-
-   
-
-   
-   
-   /** Make sure redelivered flag is set on redelivery via rollback*/
+   /**
+    * Make sure redelivered flag is set on redelivery via rollback
+    */
    public void testRedeliveredQueue() throws Exception
    {
       Connection conn = null;
@@ -509,9 +504,61 @@
       }
 
    }
-   
-  
-   
+
+   /**
+    * Make sure redelivered flag is set on redelivery via rollback, different setup
+    */
+   public void testRedeliveredQueue2() throws Exception
+   {
+      Connection conn = null;
+
+      try
+      {
+         conn = cf.createConnection();
+
+         Session sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
+         MessageProducer prod = sess.createProducer(queue);
+         prod.send(sess.createTextMessage("a message"));
+
+         log.debug("Message was sent to the queue");
+
+         conn.close();
+
+         conn = cf.createConnection();
+         sess = conn.createSession(true, Session.SESSION_TRANSACTED);
+
+         MessageConsumer cons = sess.createConsumer(queue);
+
+         conn.start();
+
+         TextMessage tm = (TextMessage)cons.receive();
+
+         assertEquals("a message", tm.getText());
+         assertFalse(tm.getJMSRedelivered());
+
+         sess.rollback();
+         sess.close();
+
+         sess = conn.createSession(true, Session.SESSION_TRANSACTED);
+
+         cons = sess.createConsumer(queue);
+
+         tm = (TextMessage)cons.receive();
+
+         assertEquals("a message", tm.getText());
+         assertTrue(tm.getJMSRedelivered());
+
+         sess.commit();
+      }
+      finally
+      {
+         if (conn != null)
+         {
+            conn.close();
+         }
+      }
+   }
+
    public void testReceivedRollbackQueue() throws Exception
    {
       Connection conn = cf.createConnection();