[jboss-cvs] JBossAS SVN: r63852 - in trunk/ejb3/src: test/org/jboss/ejb3/test/mdb and 1 other directory.

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

Author: bdecoste
Date: 2007-07-05 19:18:32 -0400 (Thu, 05 Jul 2007)
New Revision: 63852

Modified:
   trunk/ejb3/src/main/org/jboss/ejb3/mdb/MessagingContainer.java
   trunk/ejb3/src/test/org/jboss/ejb3/test/mdb/OverrideTestMDB.java
   trunk/ejb3/src/test/org/jboss/ejb3/test/mdb/QueueTestMDB.java
   trunk/ejb3/src/test/org/jboss/ejb3/test/mdb/TransactionQueueTestMDB.java
Log:
[EJBTHREE-1003] @PoolClass for MDBs

Modified: trunk/ejb3/src/main/org/jboss/ejb3/mdb/MessagingContainer.java
===================================================================
--- trunk/ejb3/src/main/org/jboss/ejb3/mdb/MessagingContainer.java	2007-07-05 22:43:04 UTC (rev 63851)
+++ trunk/ejb3/src/main/org/jboss/ejb3/mdb/MessagingContainer.java	2007-07-05 23:18:32 UTC (rev 63852)
@@ -309,12 +309,6 @@
    protected void initializePool() throws Exception
    {
      super.initializePool();
-     
-     String maxSession = getMaxSession();
-     if (maxSession != null)
-     {
-        pool.setMaxSize(Integer.parseInt(maxSession));
-     }
    }
    
    protected String getProviderAdapterJNDI()

Modified: trunk/ejb3/src/test/org/jboss/ejb3/test/mdb/OverrideTestMDB.java
===================================================================
--- trunk/ejb3/src/test/org/jboss/ejb3/test/mdb/OverrideTestMDB.java	2007-07-05 22:43:04 UTC (rev 63851)
+++ trunk/ejb3/src/test/org/jboss/ejb3/test/mdb/OverrideTestMDB.java	2007-07-05 23:18:32 UTC (rev 63852)
@@ -28,6 +28,7 @@
 import javax.jms.MessageListener;
 import javax.annotation.Resource;
 
+import org.jboss.annotation.ejb.PoolClass;
 import org.jboss.logging.Logger;
 
 /**
@@ -39,6 +40,7 @@
         @ActivationConfigProperty(propertyName="destinationType", propertyValue="javax.jms.Bogus"),
         @ActivationConfigProperty(propertyName="destination", propertyValue="queue/bogus")
         })
+ at PoolClass(value=org.jboss.ejb3.StrictMaxPool.class, maxSize=100, timeout=10000)
 public class OverrideTestMDB implements MessageListener
 {
    private static final Logger log = Logger.getLogger(OverrideTestMDB.class);

Modified: trunk/ejb3/src/test/org/jboss/ejb3/test/mdb/QueueTestMDB.java
===================================================================
--- trunk/ejb3/src/test/org/jboss/ejb3/test/mdb/QueueTestMDB.java	2007-07-05 22:43:04 UTC (rev 63851)
+++ trunk/ejb3/src/test/org/jboss/ejb3/test/mdb/QueueTestMDB.java	2007-07-05 23:18:32 UTC (rev 63852)
@@ -36,6 +36,7 @@
 
 import javax.annotation.security.RunAs;
 
+import org.jboss.annotation.ejb.PoolClass;
 import org.jboss.annotation.security.SecurityDomain;
 import org.jboss.logging.Logger;
 
@@ -50,6 +51,7 @@
         @ActivationConfigProperty(propertyName="destinationType", propertyValue="javax.jms.Queue"),
         @ActivationConfigProperty(propertyName="destination", propertyValue="queue/mdbtest")
         })
+ at PoolClass(value=org.jboss.ejb3.StrictMaxPool.class, maxSize=1, timeout=10000)
 @RunAs("TestRole")
 @SecurityDomain(value="other",unauthenticatedPrincipal="nobody")
 public class QueueTestMDB implements MessageListener

Modified: trunk/ejb3/src/test/org/jboss/ejb3/test/mdb/TransactionQueueTestMDB.java
===================================================================
--- trunk/ejb3/src/test/org/jboss/ejb3/test/mdb/TransactionQueueTestMDB.java	2007-07-05 22:43:04 UTC (rev 63851)
+++ trunk/ejb3/src/test/org/jboss/ejb3/test/mdb/TransactionQueueTestMDB.java	2007-07-05 23:18:32 UTC (rev 63852)
@@ -28,6 +28,7 @@
 import javax.jms.Message;
 import javax.jms.MessageListener;
 
+import org.jboss.annotation.ejb.PoolClass;
 import org.jboss.annotation.ejb.TransactionTimeout;
 import org.jboss.logging.Logger;
 
@@ -44,6 +45,7 @@
 @TransactionTimeout(1)
 // Not allowed on a MDB
 //@TransactionAttribute(TransactionAttributeType.REQUIRES_NEW) // if we specify a tx timeout, we must start the tx
+ at PoolClass(value=org.jboss.ejb3.StrictMaxPool.class, maxSize=1, timeout=10000)
 public class TransactionQueueTestMDB implements MessageListener
 {
    private static final Logger log = Logger.getLogger(TransactionQueueTestMDB.class);