[Jboss-cvs] JBossAS SVN: r55980 - branches/JBoss_4_0_3_SP1_JBAS_3511/server/src/main/org/jboss/ejb/plugins/jms

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

Author: weston.price at jboss.com
Date: 2006-08-16 06:42:01 -0400 (Wed, 16 Aug 2006)
New Revision: 55980

Modified:
   branches/JBoss_4_0_3_SP1_JBAS_3511/server/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvoker.java
   branches/JBoss_4_0_3_SP1_JBAS_3511/server/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvokerMBean.java
Log:
[JBAS-3511] JMS asf server improvements. 

Modified: branches/JBoss_4_0_3_SP1_JBAS_3511/server/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvoker.java
===================================================================
--- branches/JBoss_4_0_3_SP1_JBAS_3511/server/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvoker.java	2006-08-16 10:41:11 UTC (rev 55979)
+++ branches/JBoss_4_0_3_SP1_JBAS_3511/server/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvoker.java	2006-08-16 10:42:01 UTC (rev 55980)
@@ -140,7 +140,16 @@
     * Maximun pool size of server sessions.
     */
    protected int maxPoolSize = 15;
-
+   
+   /** The lazyInitialization */
+   protected boolean lazyInitialization;
+   
+   /** The recycleIdleSessions */
+   protected boolean recycleIdleSessions;
+   
+   /** The idleTimeoutMinutes */
+   protected long idleTimeoutMinutes = 30 * 1000;
+   
    /**
     * Time to wait before retrying to reconnect a lost connection.
     */
@@ -304,7 +313,23 @@
    {
       this.maxMessagesNr = maxMessages;
    }
-
+   
+   public long getIdleTimeoutMinutes()
+   {
+      return this.idleTimeoutMinutes;
+      
+   }
+   
+   public boolean isLazyIntialization()
+   {
+      return this.lazyInitialization;
+   }
+   
+   public boolean isRecycleIdleSesssions()
+   {
+      return this.recycleIdleSessions;
+   }
+   
    /**
     * @jmx:managed-attribute
     */
@@ -506,7 +531,41 @@
       catch (Exception ignore)
       {
       }
+      
+      try
+      {
+         String lazy =  MetaData.getElementContent
+            (MetaData.getUniqueChild(element, "LazyInitialization"));
+         lazyInitialization = Boolean.valueOf(lazy).booleanValue(); 
+         
+      }catch(Exception ignore)
+      {
+         
+      }
+      
+      try
+      {
+         String ris =  MetaData.getElementContent
+            (MetaData.getUniqueChild(element, "RecycleIdleSessions"));
+         recycleIdleSessions = Boolean.valueOf(ris).booleanValue(); 
+         
+      }catch(Exception ignore)
+      {
+         
+      }
 
+      try
+      {
+         String it =  MetaData.getElementContent
+            (MetaData.getUniqueChild(element, "IdleSessionTimeout"));
+         idleTimeoutMinutes = Integer.valueOf(it).longValue(); 
+         
+      }catch(Exception ignore)
+      {
+         
+      }
+      
+      
       Element mdbConfig = MetaData.getUniqueChild(element, "MDBConfig");
 
       try
@@ -765,6 +824,9 @@
                keepAlive,
                true, // tx
                acknowledgeMode,
+               lazyInitialization,
+               recycleIdleSessions,
+               idleTimeoutMinutes,
                new MessageListenerImpl(this));
 
             int subscriptionDurablity = config.getSubscriptionDurability();
@@ -883,6 +945,9 @@
                keepAlive,
                true, // tx
                acknowledgeMode,
+               lazyInitialization,
+               recycleIdleSessions,
+               idleTimeoutMinutes,
                new MessageListenerImpl(this));
             log.debug("Server session pool: " + pool);
             
@@ -1241,6 +1306,9 @@
       final long keepAlive,
       final boolean isTransacted,
       final int ack,
+      final boolean lazyInit,
+      final boolean recycleIdle,
+      final long idleTimeout,
       final MessageListener listener)
       throws NamingException, JMSException
    {

Modified: branches/JBoss_4_0_3_SP1_JBAS_3511/server/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvokerMBean.java
===================================================================
--- branches/JBoss_4_0_3_SP1_JBAS_3511/server/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvokerMBean.java	2006-08-16 10:41:11 UTC (rev 55979)
+++ branches/JBoss_4_0_3_SP1_JBAS_3511/server/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvokerMBean.java	2006-08-16 10:42:01 UTC (rev 55980)
@@ -37,5 +37,11 @@
    void startDelivery() throws java.lang.Exception;
 
    void stopDelivery() throws java.lang.Exception;
-
+   
+   boolean isLazyIntialization();
+      
+   boolean isRecycleIdleSesssions();
+   
+   long getIdleTimeoutMinutes();
+   
 }