[jboss-cvs] JBoss Messaging SVN: r2630 - trunk/tests/src/org/jboss/test/messaging/jms/message.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Thu May 3 00:34:08 EDT 2007
Author: clebert.suconic at jboss.com
Date: 2007-05-03 00:34:08 -0400 (Thu, 03 May 2007)
New Revision: 2630
Modified:
trunk/tests/src/org/jboss/test/messaging/jms/message/ExpiredMessageTest.java
Log:
http://jira.jboss.org/jira/browse/JBMESSAGING-951 - update testcase
Modified: trunk/tests/src/org/jboss/test/messaging/jms/message/ExpiredMessageTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/message/ExpiredMessageTest.java 2007-05-03 03:49:30 UTC (rev 2629)
+++ trunk/tests/src/org/jboss/test/messaging/jms/message/ExpiredMessageTest.java 2007-05-03 04:34:08 UTC (rev 2630)
@@ -20,6 +20,7 @@
import javax.jms.MessageConsumer;
import javax.jms.XAConnectionFactory;
import javax.jms.XAConnection;
+import javax.jms.TextMessage;
import javax.management.ObjectName;
/**
@@ -105,12 +106,21 @@
prod.send(m);
+ assertNull(cons.receive(3000));
+
// wait for the message to die
- Thread.sleep(5000);
+ Thread.sleep(2000);
+ Queue queueExpiryQueue = (Queue)ic.lookup("/queue/expiredTarget");
- assertNull(cons.receive(3000));
+ MessageConsumer consumerExpiredQueue = session.createConsumer(queue);
+
+ TextMessage txt = (TextMessage) consumerExpiredQueue.receive(1000);
+
+ assertEquals("This message will die", txt.getText());
+
+ assertNull(consumerExpiredQueue.receive(1000));
}
finally
{
More information about the jboss-cvs-commits
mailing list