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

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

Author: estebanschifman
Date: 2006-11-05 10:18:20 -0500 (Sun, 05 Nov 2006)
New Revision: 7410

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/AbstractListener.java
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/JmsQueueListener.java
Log:
We don't FUCKING need thread pooling for RC.
Don't put unneeded obstacles in the way of tight deadlines.

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/AbstractListener.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/AbstractListener.java	2006-11-05 14:15:04 UTC (rev 7409)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/AbstractListener.java	2006-11-05 15:18:20 UTC (rev 7410)
@@ -1,7 +1,6 @@
 package org.jboss.soa.esb.listeners.message;
 
 import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
 
 import org.apache.log4j.Logger;
 import org.jboss.soa.esb.helpers.ConfigTree;
@@ -59,7 +58,7 @@
 		} else {
 			this.logger.warn("Attribute maxThreads has not been set. Action pipeline will be processed by only one thread");
 		}
-		this.pipelineExecutorPool = Executors.newFixedThreadPool(m_iMaxThr);
+//		this.pipelineExecutorPool = Executors.newFixedThreadPool(m_iMaxThr);
 	}
 
 }

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-05 14:15:04 UTC (rev 7409)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/JmsQueueListener.java	2006-11-05 15:18:20 UTC (rev 7410)
@@ -99,7 +99,8 @@
 	        		catch (ConfigurationException e)
 	    				{	_logger.error(e); 	continue; }
 	
-	        		this.pipelineExecutorPool.submit(chain);        		
+//	        		this.pipelineExecutorPool.submit(chain);
+	        		new Thread(chain).start();
 	        	}
 	        }
 	    	_controller.unRegister(_eprCategoryName, _eprName, _epr);