[jboss-svn-commits] JBL Code SVN: r7379 - 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-03 14:54:41 -0500 (Fri, 03 Nov 2006)
New Revision: 7379

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/HttpListener.java
Log:
HttpListener expects an object message whose type is an org.jboss.soa.esb.message.Message

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-03 19:28:04 UTC (rev 7378)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/HttpListener.java	2006-11-03 19:54:41 UTC (rev 7379)
@@ -33,12 +33,9 @@
 import org.jboss.remoting.callback.InvokerCallbackHandler;
 import org.jboss.remoting.transport.Connector;
 import org.jboss.soa.esb.ConfigurationException;
-import org.jboss.soa.esb.actions.ActionUtils;
 import org.jboss.soa.esb.helpers.ConfigTree;
 import org.jboss.soa.esb.listeners.ListenerInitializationException;
 import org.jboss.soa.esb.message.Message;
-import org.jboss.soa.esb.message.format.MessageFactory;
-import org.jboss.soa.esb.message.format.MessageType;
 
 /**
  * Http listener implementation using the JBoss Remoting channel.
@@ -46,13 +43,15 @@
  * The listener will listen to messages on the configured listenHttpUrl. If this
  * is not set, the default http://localhost:5400 will be used.
  * 
+ * This listener expects an Object message whose type is org.jboss.soa.esb.message.Message
+ * 
  * Sample listener Configuration:
  * 
- * <HttpListener listenerClass="org.jboss.soa.esb.listeners.message.HttpListener" actions="HttpInvocationToFile"/>
+ * <HttpListener listenerClass="org.jboss.soa.esb.listeners.message.HttpListener"/>
  * 
  * <pre>
  *  &lt;HttpListener listenerClass=&quot;org.jboss.soa.esb.listeners.message.HttpListener&quot;&gt; 
- *  	&lt;action class=&quotorg.jboss.soa.esb.actions.routing.EchoRouter&quot;/&gt;     
+ *   	&lt;action class=&amp;quotorg.jboss.soa.esb.actions.routing.EchoRouter&quot;/&gt;     
  *  &lt;/HttpListener&gt;
  * </pre>
  * 
@@ -118,19 +117,17 @@
 					.info("HttpInvocationListener is invoked...The given payload is : "
 							+ payload);
 		}
-		// Message creation...
-		Message msg = MessageFactory.getInstance().getMessage(
-				MessageType.JAVA_SERIALIZED);
-		ActionUtils.setTaskObject(msg,payload);
-		
+		if (payload instanceof Message){
 		// Start the action processing pipeline
 		ActionProcessingPipeline pipelineRunner = new ActionProcessingPipeline(
-				msg, this._config);
+						(Message)payload, this._config);
 		this.pipelineExecutorPool.submit(pipelineRunner);
+		} else {
+			this.logger.error("Unsupported HttpListener message type: " + payload.getClass().getName());
+		}
 		
 		return payload;
 	}
-
 	/**
 	 * Adds a callback handler that will listen for callbacks from the server
 	 * invoker handler.
@@ -197,7 +194,9 @@
 		if (this.listenHttpUrl == null) {
 			this.listenHttpUrl = this.getDefaultListenHttpUrl();
 			if (this.logger.isInfoEnabled()){
-				this.logger.info("Attribute listenHttpUrl has not been set on the HttpListener. Using default " + this.getDefaultListenHttpUrl());
+				this.logger
+						.info("Attribute listenHttpUrl has not been set on the HttpListener. Using default "
+								+ this.getDefaultListenHttpUrl());
 			}
 		}
 	}