[jboss-svn-commits] JBL Code SVN: r27407 - in labs/jbossesb/workspace/dward/wsproxy/product: services/soap/src/main/java/org/jboss/soa/esb/actions/soap/proxy and 1 other directory.

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

Author: dward
Date: 2009-07-01 14:13:09 -0400 (Wed, 01 Jul 2009)
New Revision: 27407

Modified:
   labs/jbossesb/workspace/dward/wsproxy/product/samples/quickstarts/webservice_wsproxy_basic/jboss-esb.xml
   labs/jbossesb/workspace/dward/wsproxy/product/services/soap/src/main/java/org/jboss/soa/esb/actions/soap/proxy/HttpSOAPProxyTransport.java
   labs/jbossesb/workspace/dward/wsproxy/product/services/soap/src/main/java/org/jboss/soa/esb/actions/soap/proxy/SOAPProxy.java
Log:


Modified: labs/jbossesb/workspace/dward/wsproxy/product/samples/quickstarts/webservice_wsproxy_basic/jboss-esb.xml
===================================================================
--- labs/jbossesb/workspace/dward/wsproxy/product/samples/quickstarts/webservice_wsproxy_basic/jboss-esb.xml	2009-07-01 18:04:37 UTC (rev 27406)
+++ labs/jbossesb/workspace/dward/wsproxy/product/samples/quickstarts/webservice_wsproxy_basic/jboss-esb.xml	2009-07-01 18:13:09 UTC (rev 27407)
@@ -2,7 +2,7 @@
 <jbossesb xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.1.0.xsd" parameterReloadSecs="5">
 
 	<providers>
-		<jbr-provider name="JBR-Http" protocol="http">
+		<jbr-provider name="JBR-Http" protocol="http" host="localhost">
 			<jbr-bus busid="Http-1" port="9090"/>
 		</jbr-provider>
 	</providers>

Modified: labs/jbossesb/workspace/dward/wsproxy/product/services/soap/src/main/java/org/jboss/soa/esb/actions/soap/proxy/HttpSOAPProxyTransport.java
===================================================================
--- labs/jbossesb/workspace/dward/wsproxy/product/services/soap/src/main/java/org/jboss/soa/esb/actions/soap/proxy/HttpSOAPProxyTransport.java	2009-07-01 18:04:37 UTC (rev 27406)
+++ labs/jbossesb/workspace/dward/wsproxy/product/services/soap/src/main/java/org/jboss/soa/esb/actions/soap/proxy/HttpSOAPProxyTransport.java	2009-07-01 18:13:09 UTC (rev 27407)
@@ -26,6 +26,7 @@
 import org.jboss.soa.esb.actions.routing.http.HttpRouter;
 import org.jboss.soa.esb.helpers.ConfigTree;
 import org.jboss.soa.esb.message.Message;
+import org.jboss.soa.esb.message.MessagePayloadProxy;
 
 /**
  * Implements http-specific routing of the SOAP request to the target webservice.  All config properties are passed through to a
@@ -41,14 +42,19 @@
 	private String endpointAddress;
 	private HttpRouter router;
 	
-	HttpSOAPProxyTransport(ConfigTree config, String defaultEndpointAddress) throws ConfigurationException
+	HttpSOAPProxyTransport(ConfigTree config, final MessagePayloadProxy payloadProxy, String defaultEndpointAddress) throws ConfigurationException
 	{
 		ConfigTree cloned_config = config.cloneObj();
 		setAttribute(cloned_config, "MappedHeaderList", "SOAPAction, Content-Type, Accept");
 		setAttribute(cloned_config, "method", "POST");
 		setAttribute(cloned_config, "responseType", "STRING");
 		endpointAddress = setAttribute(cloned_config, "endpointUrl", defaultEndpointAddress);
-		router = new HttpRouter(cloned_config);
+		router = new HttpRouter(cloned_config) {
+			@Override
+			public MessagePayloadProxy getPayloadProxy() {
+				return payloadProxy;
+			}
+		};
 	}
 	
 	public String getEndpointAddress()

Modified: labs/jbossesb/workspace/dward/wsproxy/product/services/soap/src/main/java/org/jboss/soa/esb/actions/soap/proxy/SOAPProxy.java
===================================================================
--- labs/jbossesb/workspace/dward/wsproxy/product/services/soap/src/main/java/org/jboss/soa/esb/actions/soap/proxy/SOAPProxy.java	2009-07-01 18:04:37 UTC (rev 27406)
+++ labs/jbossesb/workspace/dward/wsproxy/product/services/soap/src/main/java/org/jboss/soa/esb/actions/soap/proxy/SOAPProxy.java	2009-07-01 18:13:09 UTC (rev 27407)
@@ -133,7 +133,7 @@
 				String endpointAddress = wsdl_end.getAddress();
 				if ( endpointAddress.toLowerCase().startsWith("http") )
 				{
-					transport = new HttpSOAPProxyTransport(config, endpointAddress);
+					transport = new HttpSOAPProxyTransport(config, payloadProxy, endpointAddress);
 				}
 				// else if jms ...
 				if (transport != null)