[jboss-cvs] JBoss Messaging SVN: r2499 - trunk/tests/src/org/jboss/test/messaging/jms.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Wed Feb 28 11:55:55 EST 2007
Author: clebert.suconic at jboss.com
Date: 2007-02-28 11:55:55 -0500 (Wed, 28 Feb 2007)
New Revision: 2499
Modified:
trunk/tests/src/org/jboss/test/messaging/jms/QueueTest.java
Log:
Minor changes
Modified: trunk/tests/src/org/jboss/test/messaging/jms/QueueTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/QueueTest.java 2007-02-28 16:13:48 UTC (rev 2498)
+++ trunk/tests/src/org/jboss/test/messaging/jms/QueueTest.java 2007-02-28 16:55:55 UTC (rev 2499)
@@ -125,12 +125,8 @@
Connection conn1 = cf.createConnection();
- assertEquals(0, ((JBossConnection)conn1).getServerID());
-
Connection conn2 = cf.createConnection();
- assertEquals(0, ((JBossConnection)conn2).getServerID());
-
try
{
Session s = conn1.createSession(true, Session.AUTO_ACKNOWLEDGE);
@@ -146,11 +142,13 @@
Session s2 = conn2.createSession(true, Session.AUTO_ACKNOWLEDGE);
- // these next three lines are an anti-pattern but they shouldn't loose any messages
+ // Create a consumer, start the session, close the consumer..
+ // This shouldn't cause any message to be lost
MessageConsumer c2 = s2.createConsumer(queue);
conn2.start();
c2.close();
+ // open a new consumer
c2 = s2.createConsumer(queue);
for (int i = 0; i < 20; i++)
More information about the jboss-cvs-commits
mailing list