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

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

Author: kurt.stam at jboss.com
Date: 2006-11-15 15:14:38 -0500 (Wed, 15 Nov 2006)
New Revision: 7626

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/HttpListener.java
   labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/listeners/message/HttpListenerConfig.xml
   labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/listeners/message/HttpListenerTest.java
Log:
Fixing qa test, removing the use of threadpooling.

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/HttpListener.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/HttpListener.java	2006-11-15 20:13:41 UTC (rev 7625)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/HttpListener.java	2006-11-15 20:14:38 UTC (rev 7626)
@@ -121,7 +121,9 @@
 		// Start the action processing pipeline
 		ActionProcessingPipeline pipelineRunner = new ActionProcessingPipeline(
 						(Message)payload, this._config);
-		this.pipelineExecutorPool.submit(pipelineRunner);
+		//this.pipelineExecutorPool.submit(pipelineRunner);
+		//The above does not invoke the process action, using the following instead.
+		new Thread(pipelineRunner).start();
 		} else {
 			this.logger.error("Unsupported HttpListener message type: " + payload.getClass().getName());
 		}

Modified: labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/listeners/message/HttpListenerConfig.xml
===================================================================
--- labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/listeners/message/HttpListenerConfig.xml	2006-11-15 20:13:41 UTC (rev 7625)
+++ labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/listeners/message/HttpListenerConfig.xml	2006-11-15 20:14:38 UTC (rev 7626)
@@ -8,6 +8,6 @@
 	>
 
 	<HttpListenerTest listenerClass="org.jboss.soa.esb.listeners.message.HttpListener" maxThreads="10">
-		<action class="org.jboss.soa.esb.listeners.message.MessageBox" />
+		<action name="MessageBox" class="org.jboss.soa.esb.listeners.message.MessageBox" />
 	</HttpListenerTest>	
 </JBossESB>
\ No newline at end of file

Modified: labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/listeners/message/HttpListenerTest.java
===================================================================
--- labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/listeners/message/HttpListenerTest.java	2006-11-15 20:13:41 UTC (rev 7625)
+++ labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/listeners/message/HttpListenerTest.java	2006-11-15 20:14:38 UTC (rev 7626)
@@ -30,6 +30,7 @@
 import org.jboss.soa.esb.message.Message;
 import org.jboss.soa.esb.message.format.MessageFactory;
 import org.jboss.soa.esb.message.format.MessageType;
+import org.jboss.soa.esb.testutils.TestEnvironmentUtil;
 import org.jboss.soa.esb.util.ClassUtils;
 import org.jboss.soa.esb.util.JMSClientUtil;
 import org.jboss.soa.esb.util.NewListenerUtils;
@@ -44,10 +45,12 @@
 
     protected void setUp() throws Exception {
         // Start the listener...
-        listenersMgr = NewListenerUtils.startListeners(ClassUtils.toResourcePath(getClass().getPackage()) + "/HttpListenerConfig.xml");
+        listenersMgr = NewListenerUtils.startListeners(TestEnvironmentUtil.getUserDir("qa") + 
+        		"junit/src" + ClassUtils.toResourcePath(getClass().getPackage()) + "/HttpListenerConfig.xml");
     }
 
     public void test() throws Throwable {
+    	Thread.sleep(1000);
         // There should have been no exceptions...
         listenersMgr.assertNotInException();