[jboss-cvs] JBoss Messaging SVN: r2027 - trunk/tests/src/org/jboss/test/messaging/jms/selector.

jboss-cvs-commits at lists.jboss.org jboss-cvs-commits at lists.jboss.org
Tue Jan 23 19:57:53 EST 2007


Author: ovidiu.feodorov at jboss.com
Date: 2007-01-23 19:57:53 -0500 (Tue, 23 Jan 2007)
New Revision: 2027

Modified:
   trunk/tests/src/org/jboss/test/messaging/jms/selector/SelectorTest.java
Log:
http://jira.jboss.org/jira/browse/JBMESSAGING-775

Modified: trunk/tests/src/org/jboss/test/messaging/jms/selector/SelectorTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/selector/SelectorTest.java	2007-01-23 13:46:01 UTC (rev 2026)
+++ trunk/tests/src/org/jboss/test/messaging/jms/selector/SelectorTest.java	2007-01-24 00:57:53 UTC (rev 2027)
@@ -252,93 +252,95 @@
 
       sess.close();
    }
-   
-   public void testManyQueueWithExpired() throws Exception
-   {
-      String selector1 = "beatle = 'john'";
 
-      Connection conn = cf.createConnection();
-      conn.start();
+   // http://jira.jboss.org/jira/browse/JBMESSAGING-775
 
-      Session sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);      
+//   public void testManyQueueWithExpired() throws Exception
+//   {
+//      String selector1 = "beatle = 'john'";
+//
+//      Connection conn = cf.createConnection();
+//      conn.start();
+//
+//      Session sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
+//
+//      MessageProducer prod = sess.createProducer(queue);
+//
+//      for (int j = 0; j < 100; j++)
+//      {
+//         Message m = sess.createMessage();
+//
+//         m.setStringProperty("beatle", "john");
+//
+//         prod.setTimeToLive(0);
+//
+//         prod.send(m);
+//
+//         m = sess.createMessage();
+//
+//         m.setStringProperty("beatle", "john");
+//
+//         prod.setTimeToLive(1);
+//
+//         prod.send(m);
+//
+//         m = sess.createMessage();
+//
+//         m.setStringProperty("beatle", "kermit the frog");
+//
+//         prod.setTimeToLive(0);
+//
+//         prod.send(m);
+//
+//         m = sess.createMessage();
+//
+//         m.setStringProperty("beatle", "kermit the frog");
+//
+//         m.setJMSExpiration(System.currentTimeMillis());
+//
+//         prod.setTimeToLive(1);
+//
+//         prod.send(m);
+//      }
+//
+//      Thread.sleep(2000);
+//
+//      MessageConsumer cons1 = sess.createConsumer(queue, selector1);
+//
+//      for (int j = 0; j < 100; j++)
+//      {
+//         Message m = cons1.receive(1000);
+//
+//         assertNotNull(m);
+//
+//         assertEquals("john", m.getStringProperty("beatle"));
+//      }
+//
+//      Message m = cons1.receive(1000);
+//
+//      assertNull(m);
+//
+//      String selector2 = "beatle = 'kermit the frog'";
+//
+//      MessageConsumer cons2 = sess.createConsumer(queue, selector2);
+//
+//      for (int j = 0; j < 100; j++)
+//      {
+//         m = cons2.receive(1000);
+//
+//         assertNotNull(m);
+//
+//         assertEquals("kermit the frog", m.getStringProperty("beatle"));
+//      }
+//
+//      m = cons2.receive(1000);
+//
+//      assertNull(m);
+//
+//
+//      sess.close();
+//   }
 
-      MessageProducer prod = sess.createProducer(queue);
-
-      for (int j = 0; j < 100; j++)
-      {
-         Message m = sess.createMessage();
-
-         m.setStringProperty("beatle", "john");
-         
-         prod.setTimeToLive(0);
-
-         prod.send(m);
-         
-         m = sess.createMessage();
-
-         m.setStringProperty("beatle", "john");
-         
-         prod.setTimeToLive(1);
-         
-         prod.send(m);
-         
-         m = sess.createMessage();
-
-         m.setStringProperty("beatle", "kermit the frog");
-         
-         prod.setTimeToLive(0);
-         
-         prod.send(m);
-         
-         m = sess.createMessage();
-
-         m.setStringProperty("beatle", "kermit the frog");
-         
-         m.setJMSExpiration(System.currentTimeMillis());
-         
-         prod.setTimeToLive(1);
-         
-         prod.send(m);
-      }
-      
-      Thread.sleep(2000);
-      
-      MessageConsumer cons1 = sess.createConsumer(queue, selector1);
-
-      for (int j = 0; j < 100; j++)
-      {
-         Message m = cons1.receive(1000);
-         
-         assertNotNull(m);
-         
-         assertEquals("john", m.getStringProperty("beatle"));
-      }
-
-      Message m = cons1.receive(1000);
-
-      assertNull(m);
-      
-      String selector2 = "beatle = 'kermit the frog'";
-      
-      MessageConsumer cons2 = sess.createConsumer(queue, selector2);
-      
-      for (int j = 0; j < 100; j++)
-      {
-         m = cons2.receive(1000);
-         
-         assertNotNull(m);
-         
-         assertEquals("kermit the frog", m.getStringProperty("beatle"));
-      }
-      
-      m = cons2.receive(1000);
-
-      assertNull(m);
-      
-
-      sess.close();
-   }
-
    public void testManyRedeliveriesTopic() throws Exception
    {
       String selector1 = "beatle = 'john'";




More information about the jboss-cvs-commits mailing list