[jboss-cvs] JBossAS SVN: r58080 - 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-11-03 13:33:10 -0500 (Fri, 03 Nov 2006)
New Revision: 58080

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] ASF improvements and patch.

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-11-03 18:11:49 UTC (rev 58079)
+++ branches/JBoss_4_0_3_SP1_JBAS_3511/server/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvoker.java	2006-11-03 18:33:10 UTC (rev 58080)
@@ -162,6 +162,11 @@
    /** The alwaysReconnect */
    protected boolean alwaysReconnect;
    
+   protected boolean destroySessionOnError = false;
+   
+   //Default
+   protected String exceptionSorterClassName = "org.jboss.jms.asf.NullJMSExceptionSorter";
+   
    /**
     * Time to wait before retrying to reconnect a lost connection.
     */
@@ -423,6 +428,31 @@
       
    }
    
+   public int getSessionErrorCount()
+   {
+      int error = 0;
+      
+      if(pool != null)
+      {
+         StdServerSessionPool sp = (StdServerSessionPool)pool;
+         error = sp.getSessionErrorCount();
+         
+      }
+      return error;
+   }
+   
+   public int getSessionCreatedCount()
+   {
+      int total;
+      
+      if(pool != null)
+      {
+         StdServerSessionPool sp = (StdServerSessionPool)pool;
+         total = sp.getSessionCreatedCount();
+         
+      }      
+      return 0;
+   }
    /**
     * @jmx:managed-attribute
     */
@@ -670,6 +700,27 @@
       {
          
       }
+
+      try
+      {
+         String destroy =  MetaData.getElementContent
+            (MetaData.getUniqueChild(element, "DestroySessionOnError"));
+         destroySessionOnError = Boolean.valueOf(destroy).booleanValue(); ; 
+         
+      }catch(Exception ignore)
+      {
+         
+      }
+
+      try
+      {
+         String exceptionSorter =  MetaData.getElementContent
+            (MetaData.getUniqueChild(element, "ExceptionSorterClassName"));
+         
+      }catch(Exception ignore)
+      {
+         
+      }
       
       
       Element mdbConfig = MetaData.getUniqueChild(element, "MDBConfig");
@@ -1438,7 +1489,7 @@
             context.lookup(serverSessionPoolFactoryJNDI);
          
          // the create the pool
-         pool = factory.getServerSessionPool(destination, connection, minSession, maxSession, keepAlive, isTransacted, ack, !isContainerManagedTx || isNotSupportedTx, lazyInit, recycleIdle, idleTimeout, listener);
+         pool = factory.getServerSessionPool(destination, connection, minSession, maxSession, keepAlive, isTransacted, ack, !isContainerManagedTx || isNotSupportedTx, lazyInit, recycleIdle, idleTimeout, destroySessionOnError, exceptionSorterClassName, listener);
       }
       finally
       {

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-11-03 18:11:49 UTC (rev 58079)
+++ branches/JBoss_4_0_3_SP1_JBAS_3511/server/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvokerMBean.java	2006-11-03 18:33:10 UTC (rev 58080)
@@ -59,6 +59,10 @@
    
    int getMaxSessionInUseCount();
    
+   int getSessionErrorCount();
+   
+   int getSessionCreatedCount();
+   
    void setAlwaysReconnect(boolean alwaysReconnect);
    
    boolean getAlwaysReconnect();