[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