[jboss-cvs] JBoss Messaging SVN: r3301 - branches/Branch_Stable/tests/src/org/jboss/test/messaging/jms.

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

Author: clebert.suconic at jboss.com
Date: 2007-11-08 12:26:46 -0500 (Thu, 08 Nov 2007)
New Revision: 3301

Modified:
   branches/Branch_Stable/tests/src/org/jboss/test/messaging/jms/BrowserTest.java
Log:
http://jira.jboss.org/jira/browse/JBMESSAGING-1144

Modified: branches/Branch_Stable/tests/src/org/jboss/test/messaging/jms/BrowserTest.java
===================================================================
--- branches/Branch_Stable/tests/src/org/jboss/test/messaging/jms/BrowserTest.java	2007-11-08 11:48:19 UTC (rev 3300)
+++ branches/Branch_Stable/tests/src/org/jboss/test/messaging/jms/BrowserTest.java	2007-11-08 17:26:46 UTC (rev 3301)
@@ -31,6 +31,7 @@
 import javax.jms.QueueBrowser;
 import javax.jms.Session;
 import javax.jms.TextMessage;
+import javax.jms.DeliveryMode;
 
 import org.jboss.jms.destination.JBossQueue;
 
@@ -293,6 +294,64 @@
 		}
    }
 
+
+   // Testcase for http://jira.jboss.org/jira/browse/JBMESSAGING-1144
+   public void testMessageOrderOnBrowser() throws Exception
+   {
+
+      Connection conn = cf.createConnection();
+      try
+      {
+         conn.start();
+
+         Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
+         MessageProducer sender = session.createProducer(queue1);
+
+         TextMessage message = session.createTextMessage();
+         message.setText("Normal message");
+         sender.send(message, DeliveryMode.NON_PERSISTENT, 4, 0);
+         //sender.send(queue, message, DeliveryMode.NON_PERSISTENT, 4, 0);
+         message.setText("Persistent message");
+         sender.send(message, DeliveryMode.PERSISTENT, 4, 0);
+         //sender.send(queue, message, DeliveryMode.PERSISTENT, 4, 0);
+         message.setText("High Priority Persistent message");
+         sender.send(message, DeliveryMode.PERSISTENT, 10, 0);
+         //sender.send(queue, message, DeliveryMode.PERSISTENT, 10, 0);
+
+         //message.setText("Expiring Persistent message");
+         //sender.send(queue, message, DeliveryMode.NON_PERSISTENT, 4, 1);
+
+         QueueBrowser browser = session.createBrowser(queue1);
+         Enumeration i = browser.getEnumeration();
+         //message = (TextMessage)enum.nextElement();
+         //if( !message.getText().equals("High Priority Persistent message") )
+         //	throw new Exception("Queue is not prioritizing messages correctly. Unexpected Message:"+message);
+         log.info(message.getText());
+
+         message = (TextMessage) i.nextElement();
+         //if( !message.getText().equals("Normal message") )
+         //	throw new Exception("Queue is not ordering messages correctly. Unexpected Message:"+message);
+         log.info(message.getText());
+
+         message = (TextMessage) i.nextElement();
+         //if( !message.getText().equals("Persistent message") )
+         //	throw new Exception("Queue is not ordering messages correctly. Unexpected Message:"+message);
+         log.info(message.getText());
+
+         // if( enum.hasMoreElements() )
+         //	throw new Exception("Queue does not expire messages correctly. Unexpected Message:"+enum.nextElement());
+      }
+      finally
+      {
+         if (conn!=null)
+         {
+            conn.close();
+         }
+      }
+
+   }
+
+   
    // Package protected ----------------------------------------------------------------------------
 	
 	// Protected ------------------------------------------------------------------------------------