[jboss-cvs] JBossAS SVN: r64355 - trunk/testsuite/src/main/org/jboss/test/cts/test.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2007-07-30 17:51:29 -0400 (Mon, 30 Jul 2007)
New Revision: 64355

Modified:
   trunk/testsuite/src/main/org/jboss/test/cts/test/MDBUnitTestCase.java
Log:
Fixing flawed test

Modified: trunk/testsuite/src/main/org/jboss/test/cts/test/MDBUnitTestCase.java
===================================================================
--- trunk/testsuite/src/main/org/jboss/test/cts/test/MDBUnitTestCase.java	2007-07-30 21:06:50 UTC (rev 64354)
+++ trunk/testsuite/src/main/org/jboss/test/cts/test/MDBUnitTestCase.java	2007-07-30 21:51:29 UTC (rev 64355)
@@ -54,19 +54,19 @@
       InitialContext ctx = new InitialContext();
       QueueConnectionFactory factory = (QueueConnectionFactory) ctx.lookup(QUEUE_FACTORY);
       QueueConnection queConn = factory.createQueueConnection();
-      QueueSession session = queConn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
       Queue queueA = (Queue) ctx.lookup("queue/A");
       Queue queueB = (Queue) ctx.lookup("queue/B");
       queConn.start();
       MDBInvoker[] threads = new MDBInvoker[MAX_SIZE];
       for(int n = 0; n < MAX_SIZE; n ++)
       {
+    	 // Each thread should own its own session, accordingly to the JMS spec
+         QueueSession session = queConn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
          MDBInvoker t = new MDBInvoker(session, queueA, queueB, n, done, getLog());
          threads[n] = t;
          t.start();
       }
       assertTrue("Acquired done", done.attempt(1500 * MAX_SIZE));
-      session.close();
       queConn.close();
 
       for(int n = 0; n < MAX_SIZE; n ++)
@@ -75,7 +75,7 @@
          if( t.runEx != null )
          {
             t.runEx.printStackTrace();
-            fail("Inovker.runEx != null, msg="+t.runEx.getMessage());
+            throw t.runEx;
          }
       }
    }