[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