[jboss-svn-commits] JBL Code SVN: r7298 - labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message

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

Author: jokum
Date: 2006-11-01 18:01:54 -0500 (Wed, 01 Nov 2006)
New Revision: 7298

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/JmsQueueListener.java
Log:
Extends AbstractListener now

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/JmsQueueListener.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/JmsQueueListener.java	2006-11-01 23:01:20 UTC (rev 7297)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/JmsQueueListener.java	2006-11-01 23:01:54 UTC (rev 7298)
@@ -57,7 +57,7 @@
  * @since Version 4.0
  */
 
-public class JmsQueueListener implements Runnable 
+public class JmsQueueListener extends AbstractListener
 {
 	/**
 	 * public constructor
@@ -68,8 +68,7 @@
     public JmsQueueListener(EsbListenerController controller, ConfigTree config) 
     	throws ConfigurationException 
     {
-    	_controller			= controller;
-    	_config				= config;
+    	super(controller, config);
     	_iSleepForRetry		= 3;
     	checkMyParms();
     } // _______________________________
@@ -98,8 +97,7 @@
         		catch (ConfigurationException e)
     				{	_logger.error(e); 	continue; }
 
- // TODO  Take care of thread pooling and (eventually) maximum child threads
-        		new Thread(chain).start();
+        		this.pipelineExecutorPool.submit(chain);        		
         	}
         }
     	_controller.unRegister(_eprName);