[jboss-cvs] JBossAS SVN: r64356 - branches/Branch_4_4/testsuite/src/main/org/jboss/test/cts/test.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Mon Jul 30 18:17:10 EDT 2007
Author: clebert.suconic at jboss.com
Date: 2007-07-30 18:17:10 -0400 (Mon, 30 Jul 2007)
New Revision: 64356
Modified:
branches/Branch_4_4/testsuite/src/main/org/jboss/test/cts/test/MDBUnitTestCase.java
Log:
Fixing test
Modified: branches/Branch_4_4/testsuite/src/main/org/jboss/test/cts/test/MDBUnitTestCase.java
===================================================================
--- branches/Branch_4_4/testsuite/src/main/org/jboss/test/cts/test/MDBUnitTestCase.java 2007-07-30 21:51:29 UTC (rev 64355)
+++ branches/Branch_4_4/testsuite/src/main/org/jboss/test/cts/test/MDBUnitTestCase.java 2007-07-30 22:17:10 UTC (rev 64356)
@@ -54,19 +54,18 @@
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 ++)
{
+ 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 ++)
More information about the jboss-cvs-commits
mailing list