[Jboss-cvs] JBossAS SVN: r56200 - branches/JBoss_4_0_3_SP1_JBAS_3511/server/src/main/org/jboss/jms/asf

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

Author: weston.price at jboss.com
Date: 2006-08-23 18:46:44 -0400 (Wed, 23 Aug 2006)
New Revision: 56200

Modified:
   branches/JBoss_4_0_3_SP1_JBAS_3511/server/src/main/org/jboss/jms/asf/JmsServerSessionReaper.java
Log:
[JBAS-3511] Improvements for ASF integration, pool management, idle session collection
as and dynamic allocation.

Modified: branches/JBoss_4_0_3_SP1_JBAS_3511/server/src/main/org/jboss/jms/asf/JmsServerSessionReaper.java
===================================================================
--- branches/JBoss_4_0_3_SP1_JBAS_3511/server/src/main/org/jboss/jms/asf/JmsServerSessionReaper.java	2006-08-23 21:37:11 UTC (rev 56199)
+++ branches/JBoss_4_0_3_SP1_JBAS_3511/server/src/main/org/jboss/jms/asf/JmsServerSessionReaper.java	2006-08-23 22:46:44 UTC (rev 56200)
@@ -1,3 +1,4 @@
+
 package org.jboss.jms.asf;
 
 import java.util.ArrayList;
@@ -7,9 +8,11 @@
 import org.jboss.logging.Logger;
 
 /**
- * A JmsServerSessionReaper.
+ * A JmsServerSessionReaper based on JCA <code>org.jboss.resource.connectionmanager.IdleRemover</code>.
  * 
- * @author <a href="adrian at jboss.com">Adrian Brock</a>
+ * @author <a href="mailto:weston.price at jboss.com>Weston Price</a>
+ * 
+ * @see org.jboss.resource.connectionmanager.IdleRemover
  * @version $Revision: 1.1 $
  */
 public class JmsServerSessionReaper
@@ -47,7 +50,7 @@
                         try 
                         {
                            pools.wait(interval);
-                           logger.debug("run: IdleRemover notifying pools, interval: " + interval);
+                           logger.debug("run: JmsSessionReaper notifying pools, interval: " + interval);
                            
                            for (Iterator i = pools.iterator(); i.hasNext(); ) 
                            {
@@ -64,23 +67,23 @@
                         }
                         catch (InterruptedException ie)
                         {
-                           logger.info("run: IdleRemover has been interrupted, returning");
+                           logger.info("run: JmsSessionReaper has been interrupted, returning");
                            return;  
-                        } // end of try-catch
+                        } 
                         catch (RuntimeException e)
                         {
-                           logger.warn("run: IdleRemover ignored unexpected runtime exception", e);
+                           logger.warn("run: JmsSessionReaper ignored unexpected runtime exception", e);
                         }
                         catch (Error e)
                         {
-                           logger.warn("run: IdleRemover ignored unexpected error", e);
+                           logger.warn("run: JmsSessionReaper ignored unexpected error", e);
                         }
                            
                      } 
                      
                   }
                }
-            }, "IdleRemover");
+            }, "JmsSessionReaper");
          reaperThread.setDaemon(true);
          reaperThread.start();