You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by ve...@apache.org on 2008/10/29 00:51:51 UTC
svn commit: r708729 - in /synapse/trunk/java:
repository/conf/sample/synapse_sample_252.xml
src/site/xdoc/Synapse_Samples.xml
Author: veithen
Date: Tue Oct 28 16:51:51 2008
New Revision: 708729
URL: http://svn.apache.org/viewvc?rev=708729&view=rev
Log:
Fixed sample 252:
* SYNAPSE-308.
* Added transport.jms.ContentType parameter where required.
* Changed transport.jms.Wrapper parameter to Wrapper.
* Changed documentation to reflect real log output.
Modified:
synapse/trunk/java/repository/conf/sample/synapse_sample_252.xml
synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml
Modified: synapse/trunk/java/repository/conf/sample/synapse_sample_252.xml
URL: http://svn.apache.org/viewvc/synapse/trunk/java/repository/conf/sample/synapse_sample_252.xml?rev=708729&r1=708728&r2=708729&view=diff
==============================================================================
--- synapse/trunk/java/repository/conf/sample/synapse_sample_252.xml (original)
+++ synapse/trunk/java/repository/conf/sample/synapse_sample_252.xml Tue Oct 28 16:51:51 2008
@@ -21,19 +21,21 @@
<definitions xmlns="http://ws.apache.org/ns/synapse">
<sequence name="text_proxy">
+ <log level="full"/>
<header name="Action" value="urn:placeOrder"/>
<script language="js"><![CDATA[
var args = mc.getPayloadXML().toString().split(" ");
mc.setPayloadXML(
- <m:placeOrder xmlns:m="http://services.samples/xsd">
- <m:order>
- <m:price>{args[0]}</m:price>
- <m:quantity>{args[1]}</m:quantity>
- <m:symbol>{args[2]}</m:symbol>
- </m:order>
- </m:placeOrder>);
+ <placeOrder xmlns="http://services.samples">
+ <order xmlns="http://services.samples/xsd">
+ <price>{args[0]}</price>
+ <quantity>{args[1]}</quantity>
+ <symbol>{args[2]}</symbol>
+ </order>
+ </placeOrder>);
]]></script>
<property action="set" name="OUT_ONLY" value="true"/>
+ <log level="full"/>
<send>
<endpoint>
<address uri="http://localhost:9000/services/SimpleStockQuoteService"/>
@@ -42,6 +44,7 @@
</sequence>
<sequence name="mtom_proxy">
+ <log level="full"/>
<property action="set" name="OUT_ONLY" value="true"/>
<header name="Action" value="urn:oneWayUploadUsingMTOM"/>
<send>
@@ -67,13 +70,14 @@
<proxy name="JMSFileUploadProxy" transports="jms">
<target inSequence="mtom_proxy" outSequence="out"/>
- <parameter name="transport.jms.Wrapper">{http://services.samples/xsd}element</parameter>
+ <parameter name="Wrapper">{http://services.samples/xsd}element</parameter>
</proxy>
<proxy name="JMSTextProxy" transports="jms">
<target inSequence="text_proxy" outSequence="out"/>
- <parameter name="transport.jms.Wrapper">{http://services.samples/xsd}text</parameter>
+ <parameter name="Wrapper">{http://services.samples/xsd}text</parameter>
</proxy>
<proxy name="JMSPoxProxy" transports="jms">
<target inSequence="pox_proxy" outSequence="out"/>
+ <parameter name="transport.jms.ContentType">application/xml</parameter>
</proxy>
</definitions>
\ No newline at end of file
Modified: synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml
URL: http://svn.apache.org/viewvc/synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml?rev=708729&r1=708728&r2=708729&view=diff
==============================================================================
--- synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml (original)
+++ synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml Tue Oct 28 16:51:51 2008
@@ -2075,65 +2075,69 @@
<pre xml:space="preserve">Accepted order for : 18406 stocks of MSFT at $ 83.58806051152119</pre>
<h2>
<a name="Sample252" id="Sample252">Sample 252: Pure text/binary and POX message support with JMS</a></h2>
-<pre xml:space="preserve"><definitions xmlns="http://ws.apache.org/ns/synapse">
+<pre xml:space="preserve"><![CDATA[<definitions xmlns="http://ws.apache.org/ns/synapse">
- <sequence name="text_proxy">
- <header name="Action" value="urn:placeOrder"/>
- <script language="js"><![CDATA[
- var args = mc.getPayloadXML().toString().split(" ");
+ <sequence name="text_proxy">
+ <log level="full"/>
+ <header name="Action" value="urn:placeOrder"/>
+ <script language="js">]]><![CDATA[<![CDATA[
+ var args = mc.getPayloadXML().toString().split(" ");
mc.setPayloadXML(
- <m:placeOrder xmlns:m="http://services.samples/xsd">
- <m:order>
- <m:price>{args[0]}</m:price>
- <m:quantity>{args[1]}</m:quantity>
- <m:symbol>{args[2]}</m:symbol>
- </m:order>
- </m:placeOrder>);
- ]]></script>
- <property action="set" name="OUT_ONLY" value="true"/>
- <send>
- <endpoint>
- <address uri="http://localhost:9000/services/SimpleStockQuoteService"/>
- </endpoint>
- </send>
- </sequence>
-
- <sequence name="mtom_proxy">
- <property action="set" name="OUT_ONLY" value="true"/>
- <header name="Action" value="urn:oneWayUploadUsingMTOM"/>
- <send>
- <endpoint>
- <address uri="http://localhost:9000/services/MTOMSwASampleService" optimize="mtom"/>
- </endpoint>
- </send>
- </sequence>
-
- <sequence name="pox_proxy">
- <property action="set" name="OUT_ONLY" value="true"/>
- <header name="Action" value="urn:placeOrder"/>
- <send>
- <endpoint>
- <address uri="http://localhost:9000/services/SimpleStockQuoteService" format="soap11"/>
- </endpoint>
- </send>
- </sequence>
-
- <sequence name="out">
- <send/>
- </sequence>
-
- <proxy name="JMSFileUploadProxy" transports="jms">
- <target inSequence="mtom_proxy" outSequence="out"/>
- <parameter name="transport.jms.Wrapper">{http://services.samples/xsd}element</parameter>
- </proxy>
- <proxy name="JMSTextProxy" transports="jms">
- <target inSequence="text_proxy" outSequence="out"/>
- <parameter name="transport.jms.Wrapper">{http://services.samples/xsd}text</parameter>
- </proxy>
- <proxy name="JMSPoxProxy" transports="jms">
- <target inSequence="pox_proxy" outSequence="out"/>
- </proxy>
-</definitions></pre>
+ <placeOrder xmlns="http://services.samples">
+ <order xmlns="http://services.samples/xsd">
+ <price>{args[0]}</price>
+ <quantity>{args[1]}</quantity>
+ <symbol>{args[2]}</symbol>
+ </order>
+ </placeOrder>);
+ ]]>]]><![CDATA[</script>
+ <property action="set" name="OUT_ONLY" value="true"/>
+ <log level="full"/>
+ <send>
+ <endpoint>
+ <address uri="http://localhost:9000/services/SimpleStockQuoteService"/>
+ </endpoint>
+ </send>
+ </sequence>
+
+ <sequence name="mtom_proxy">
+ <log level="full"/>
+ <property action="set" name="OUT_ONLY" value="true"/>
+ <header name="Action" value="urn:oneWayUploadUsingMTOM"/>
+ <send>
+ <endpoint>
+ <address uri="http://localhost:9000/services/MTOMSwASampleService" optimize="mtom"/>
+ </endpoint>
+ </send>
+ </sequence>
+
+ <sequence name="pox_proxy">
+ <property action="set" name="OUT_ONLY" value="true"/>
+ <header name="Action" value="urn:placeOrder"/>
+ <send>
+ <endpoint>
+ <address uri="http://localhost:9000/services/SimpleStockQuoteService" format="soap11"/>
+ </endpoint>
+ </send>
+ </sequence>
+
+ <sequence name="out">
+ <send/>
+ </sequence>
+
+ <proxy name="JMSFileUploadProxy" transports="jms">
+ <target inSequence="mtom_proxy" outSequence="out"/>
+ <parameter name="Wrapper">{http://services.samples/xsd}element</parameter>
+ </proxy>
+ <proxy name="JMSTextProxy" transports="jms">
+ <target inSequence="text_proxy" outSequence="out"/>
+ <parameter name="Wrapper">{http://services.samples/xsd}text</parameter>
+ </proxy>
+ <proxy name="JMSPoxProxy" transports="jms">
+ <target inSequence="pox_proxy" outSequence="out"/>
+ <parameter name="transport.jms.ContentType">application/xml</parameter>
+ </proxy>
+</definitions>]]></pre>
<p>
<strong>Objective: Pure POX/Text and Binary JMS Proxy services - including MTOM</strong> </p>
<p>
@@ -2142,69 +2146,69 @@
<br></br> Start the Synapse configuration numbered 252: i.e. synapse -sample 252
<br></br> Start the Axis2 server and deploy the SimpleStockQuoteService and the MTOMSwASampleService if not already done </p>
<p></p>
-<p>This configuration creates three JMS proxy services named JMSFileUploadProxy, JMSTextProxy and JMSPoxProxy exposed over JMS queues with the same names as the services. The first part of this example demonstrates the pure text message support with JMS, where a user sends a space separated text JMS message of the form "<price> <qty> <symbol>". Synapse converts this message into a SOAP message and sends this to the SimpleStockQuoteServices' placeOrder operation. Synapse uses the script mediator to transform the text message into a XML payload using the JavaScript support available to tokenize the string. The proxy service property named "transport.jms.Wrapper" defines a custom wrapper element QName, to be used when wrapping text/binary content into a SOAP envelope. </p>
+<p>This configuration creates three JMS proxy services named JMSFileUploadProxy, JMSTextProxy and JMSPoxProxy exposed over JMS queues with the same names as the services. The first part of this example demonstrates the pure text message support with JMS, where a user sends a space separated text JMS message of the form "<price> <qty> <symbol>". Synapse converts this message into a SOAP message and sends this to the SimpleStockQuoteServices' placeOrder operation. Synapse uses the script mediator to transform the text message into a XML payload using the JavaScript support available to tokenize the string. The proxy service property named "Wrapper" defines a custom wrapper element QName, to be used when wrapping text/binary content into a SOAP envelope. </p>
<p></p>
<p>Execute JMS client as follows. This will post a pure text JMS message with the content defined (e.g. "12.33 1000 ACP") to the specified JMS destination - dynamicQueues/JMSTextProxy </p>
<pre xml:space="preserve">ant jmsclient -Djms_type=text -Djms_payload="12.33 1000 ACP" -Djms_dest=dynamicQueues/JMSTextProxy</pre>
-<p>Following the debug logs, you could notice that Synapse received the JMS text message and transformed it into a SOAP payload as follows. Notice that the wrapper element "{http://services.samples/xsd}text" has been used to hold the text message content. </p>
-<pre xml:space="preserve">[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Body :
-<?xml version='1.0' encoding='utf-8'?><soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
- <soapenv:Body><axis2ns1:text xmlns:axis2ns1="http://services.samples/xsd">12.33 1000 ACP</axis2ns1:text></soapenv:Body>
-</soapenv:Envelope></pre>
+<p>Following the logs, you could notice that Synapse received the JMS text message and transformed it into a SOAP payload as follows. Notice that the wrapper element "{http://services.samples/xsd}text" has been used to hold the text message content. </p>
+<pre xml:space="preserve"><![CDATA[[jms-Worker-1] INFO LogMediator To: ,
+ WSAction: urn:mediate,
+ SOAPAction: urn:mediate,
+ MessageID: ID:orcus.veithen.net-50631-1225235276233-1:0:1:1:1,
+ Direction: request,
+Envelope:
+<?xml version='1.0' encoding='utf-8'?>
+<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
+ <soapenv:Body>
+ <axis2ns1:text xmlns:axis2ns1="http://services.samples/xsd">12.33 1000 ACP</axis2ns1:text>
+ </soapenv:Body>
+</soapenv:Envelope>]]></pre>
<p>Now, you could see how the script mediator created a stock quote request by tokenizing the text as follows, and sent the message to the placeOrder operation of the SimpleStockQuoteService. </p>
-<pre xml:space="preserve">[JMSWorker-1] DEBUG AddressEndpoint - Sending message to endpoint :: name = AnonymousEndpoints resolved address = http://localhost:9000/services/SimpleStockQuoteService
-[JMSWorker-1] DEBUG AddressEndpoint - SOAPAction: urn:placeOrder
-[JMSWorker-1] DEBUG AddressEndpoint - WSA-Action: urn:placeOrder
-[JMSWorker-1] DEBUG AddressEndpoint - Body :
-<?xml version='1.0' encoding='utf-8'?><soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"><soapenv:Body>
- <m:placeOrder xmlns:m="http://services.samples/xsd"><m:order><m:price>12.33</m:price><m:quantity>1000</m:quantity><m:symbol>ACP</m:symbol></m:order>
-</m:placeOrder></soapenv:Body></soapenv:Envelope></pre>
+<pre xml:space="preserve"><![CDATA[[jms-Worker-1] INFO LogMediator To: ,
+ WSAction: urn:placeOrder,
+ SOAPAction: urn:placeOrder,
+ MessageID: ID:orcus.veithen.net-50631-1225235276233-1:0:1:1:1,
+ Direction: request,
+Envelope:
+<?xml version='1.0' encoding='utf-8'?>
+<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
+ <soapenv:Body>
+ <placeOrder xmlns="http://services.samples">
+ <order xmlns="http://services.samples/xsd">
+ <price>12.33</price>
+ <quantity>1000</quantity>
+ <symbol>ACP</symbol>
+ </order>
+ </placeOrder>
+ </soapenv:Body>
+</soapenv:Envelope>]]></pre>
<p>The sample Axis2 server would now accept the one-way message and issue the following message: </p>
-<pre xml:space="preserve">Wed Apr 25 19:50:56 LKT 2007 samples.services.SimpleStockQuoteService :: Accepted order for : 1000 stocks of ACP at $ 12.33</pre>
+<pre xml:space="preserve">samples.services.SimpleStockQuoteService :: Accepted order for : 1000 stocks of ACP at $ 12.33</pre>
<p></p>
<p>The next section of this example demonstrates how a pure binary JMS message could be received and processed through Synapse. The configuration creates a proxy service named 'JMSFileUploadProxy' that accepts binary messages and wraps them into a custom element '{http://services.samples/xsd}element'. The received message is then forwarded to the MTOMSwASampleService using the SOAP action 'urn:oneWayUploadUsingMTOM' and optimizing binary content using MTOM. To execute this sample, use the JMS client to publish a pure binary JMS message containing the file './../../repository/conf/sample/resources/mtom/asf-logo.gif' to the JMS destination 'dynamicQueues/JMSFileUploadProxy' as follows: </p>
-<pre xml:space="preserve">ant jmsclient -Djms_type=binary -Djms_dest=dynamicQueues/JMSFileUploadProxy -Djms_payload=./../../repository/conf/sample/resources/mtom/asf-logo.gif</pre>
+<pre xml:space="preserve">ant jmsclient -Djms_type=binary -Djms_dest=dynamicQueues/JMSFileUploadProxy
+ -Djms_payload=./../../repository/conf/sample/resources/mtom/asf-logo.gif</pre>
<p>Examining the Synapse debug logs reveals that the binary content was received over JMS and wrapped with the specified element into a SOAP infoset as follows: </p>
-<pre xml:space="preserve">[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Proxy Service JMSFileUploadProxy received a new message...
-...
-[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Body :
-<?xml version='1.0' encoding='utf-8'?><soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
-<soapenv:Body><axis2ns1:element xmlns:axis2ns1="http://services.samples/xsd">R0lGODlhgw...AAOw==</axis2ns1:element></soapenv:Body>
-</soapenv:Envelope></pre>
+<pre xml:space="preserve"><![CDATA[[jms-Worker-1] INFO LogMediator To: ,
+ WSAction: urn:mediate,
+ SOAPAction: urn:mediate,
+ MessageID: ID:orcus.veithen.net-50702-1225236039556-1:0:1:1:1,
+ Direction: request,
+Envelope:
+<?xml version='1.0' encoding='utf-8'?>
+<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
+ <soapenv:Body>
+ <axis2ns1:element xmlns:axis2ns1="http://services.samples/xsd">R0lGODlhgw...AAOw==</axis2ns1:element>
+ </soapenv:Body>
+</soapenv:Envelope>]]></pre>
<p>Thereafter the message was sent as a MTOM optimized message as specified by the 'format=mtom' attribute of the endpoint, to the MTOMSwASampleService using the SOAP action 'urn:oneWayUploadUsingMTOM'. Once received by the sample service, it is saved into a temporary file and could be verified for correctness. </p>
<pre xml:space="preserve">Wrote to file : ./../../work/temp/sampleServer/mtom-4417.gif</pre>
<p></p>
<p>The final section of this example shows how a POX JMS message received by Synapse is sent to the SimpleStockQuoteService as a SOAP message. Use the JMS client as follows to create a POX (Plain Old XML) message with a stock quote request payload (without a SOAP envelope), and send it to the JMS destination 'dynamicQueues/JMSPoxProxy' as follows: </p>
<pre xml:space="preserve">ant jmsclient -Djms_type=pox -Djms_dest=dynamicQueues/JMSPoxProxy -Djms_payload=MSFT</pre>
-<p>You can see that Synapse received the POX message and displays it as follows in the debug logs, and then converts it into a SOAP payload and sends to the SimpleStockQuoteService after setting the SOAP action as 'urn:placeOrder'. </p>
-<p></p>
-<pre xml:space="preserve">[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Proxy Service JMSPoxProxy received a new message...
-...
-[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Body :
-<?xml version='1.0' encoding='utf-8'?><soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"><soapenv:Body><m:placeOrder xmlns:m="http://services.samples/xsd">
- <m:order>
- <m:price>172.39703010684752</m:price>
- <m:quantity>19211</m:quantity>
- <m:symbol>MSFT</m:symbol>
- </m:order>
-</m:placeOrder></soapenv:Body></soapenv:Envelope>
-[JMSWorker-1] DEBUG ProxyServiceMessageReceiver - Using the sequence named pox_proxy for message mediation
-...
-[JMSWorker-1] DEBUG HeaderMediator - Setting header : Action to : urn:placeOrder
-...
-[JMSWorker-1] DEBUG AddressEndpoint - Sending message to endpoint :: name = AnonymousEndpoints resolved address = http://localhost:9000/services/SimpleStockQuoteService
-[JMSWorker-1] DEBUG AddressEndpoint - SOAPAction: urn:placeOrder
-[JMSWorker-1] DEBUG AddressEndpoint - Body :
-<?xml version='1.0' encoding='utf-8'?><soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"><soapenv:Body><m:placeOrder xmlns:m="http://services.samples/xsd">
- <m:order>
- <m:price>172.39703010684752</m:price>
- <m:quantity>19211</m:quantity>
- <m:symbol>MSFT</m:symbol>
- </m:order>
-</m:placeOrder></soapenv:Body></soapenv:Envelope>
-[JMSWorker-1] DEBUG Axis2FlexibleMEPClient - sending [add = false] [sec = false] [rm = false] [ mtom = false] [ swa = false] [ force soap=true; pox=false] [ to null] </pre>
-<p>The sample Axis2 server displays a successful message on the receipt of the message as: </p>
-<pre xml:space="preserve">Wed Apr 25 20:24:50 LKT 2007 samples.services.SimpleStockQuoteService :: Accepted order for : 19211 stocks of MSFT at $ 172.39703010684752</pre>
+<p>Synapse converts the POX message into a SOAP payload and sends to the SimpleStockQuoteService after setting the SOAP action as 'urn:placeOrder'.
+The sample Axis2 server displays a successful message on the receipt of the message as: </p>
+<pre xml:space="preserve">samples.services.SimpleStockQuoteService :: Accepted order for : 19211 stocks of MSFT at $ 172.39703010684752</pre>
<h2>
<a name="Sample253" id="Sample253">Sample 253: One way bridging from JMS to http and replying with a 202 Accepted response</a></h2>
<pre xml:space="preserve"><definitions xmlns="http://ws.apache.org/ns/synapse">