You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by hi...@apache.org on 2009/08/18 13:00:18 UTC
svn commit: r805357 - /synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml
Author: hiranya
Date: Tue Aug 18 11:00:17 2009
New Revision: 805357
URL: http://svn.apache.org/viewvc?rev=805357&view=rev
Log:
Fixing a number of HTML encoding issues in the documentation. These issues caused the sample configurations not to be displayed properly.
Modified:
synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml
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=805357&r1=805356&r2=805357&view=diff
==============================================================================
--- synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml (original)
+++ synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml Tue Aug 18 11:00:17 2009
@@ -2019,30 +2019,30 @@
<a name="Transport" id="Transport">Transport samples and switching transports</a> </h1>
<h2>
<a name="Sample250" id="Sample250">Sample 250: Introduction to switching transports - JMS to http/s</a></h2>
-<pre xml:space="preserve"><![CDATA[<definitions xmlns="http://ws.apache.org/ns/synapse">
+<pre xml:space="preserve"><definitions xmlns="http://ws.apache.org/ns/synapse">
- <proxy name="StockQuoteProxy" transports="jms">
- <target>
- <inSequence>
- <property action="set" name="OUT_ONLY" value="true"/>
- </inSequence>
- <endpoint>
- <address uri="http://localhost:9000/services/SimpleStockQuoteService"/>
- </endpoint>
- <outSequence>
- <send/>
- </outSequence>
- </target>
- <publishWSDL uri="file:repository/conf/sample/resources/proxy/sample_proxy_1.wsdl"/>
- <parameter name="transport.jms.ContentType">
- <rules>
- <jmsProperty>contentType</jmsProperty>
- <default>application/xml</default>
- </rules>
- </parameter>
- </proxy>
+ <proxy name="StockQuoteProxy" transports="jms">
+ <target>
+ <inSequence>
+ <property action="set" name="OUT_ONLY" value="true"/>
+ </inSequence>
+ <endpoint>
+ <address uri="http://localhost:9000/services/SimpleStockQuoteService"/>
+ </endpoint>
+ <outSequence>
+ <send/>
+ </outSequence>
+ </target>
+ <publishWSDL uri="file:repository/conf/sample/resources/proxy/sample_proxy_1.wsdl"/>
+ <parameter name="transport.jms.ContentType">
+ <rules>
+ <jmsProperty>contentType</jmsProperty>
+ <default>application/xml</default>
+ </rules>
+ </parameter>
+ </proxy>
-</definitions>]]></pre>
+</definitions></pre>
<p>
<strong>Objective: Introduction to switching transports with proxy services</strong> </p>
<p>
@@ -2111,79 +2111,78 @@
<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"><![CDATA[<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[<![CDATA[
- var args = mc.getPayloadXML().toString().split(" ");
+<pre xml:space="preserve"><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(
- <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="transport.jms.ContentType">
- <rules>
- <bytesMessage>application/octet-stream</bytesMessage>
- </rules>
- </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.ContentType">
- <rules>
- <textMessage>text/plain</textMessage>
- </rules>
- </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>]]></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>);
+ ]]></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="transport.jms.ContentType">
+ <rules>
+ <bytesMessage>application/octet-stream</bytesMessage>
+ </rules>
+ </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.ContentType">
+ <rules>
+ <textMessage>text/plain</textMessage>
+ </rules>
+ </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></pre>
<p>
<strong>Objective: Pure POX/Text and Binary JMS Proxy services - including MTOM</strong> </p>
<p>
@@ -2197,37 +2196,29 @@
<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 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,
+<pre xml:space="preserve">[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>
+<?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"><![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,
+<pre xml:space="preserve">[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>
+<?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">samples.services.SimpleStockQuoteService :: Accepted order for : 1000 stocks of ACP at $ 12.33</pre>
<p></p>
@@ -2235,18 +2226,14 @@
<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"><![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,
+<pre xml:space="preserve">[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>
+<?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>
@@ -2317,35 +2304,35 @@
0</pre>
<h2>
<a name="Sample254" id="Sample254">Sample 254: Using the file system as transport medium using VFS transport listener and sender</a></h2>
-<pre xml:space="preserve"><![CDATA[<definitions xmlns="http://ws.apache.org/ns/synapse">
- <proxy name="StockQuoteProxy" transports="vfs">
- <parameter name="transport.vfs.FileURI">file:///home/user/test/in</parameter> <!--CHANGE-->
- <parameter name="transport.vfs.ContentType">text/xml</parameter>
- <parameter name="transport.vfs.FileNamePattern">.*\.xml</parameter>
- <parameter name="transport.PollInterval">15</parameter>
- <parameter name="transport.vfs.MoveAfterProcess">file:///home/user/test/original</parameter> <!--CHANGE-->
- <parameter name="transport.vfs.MoveAfterFailure">file:///home/user/test/original</parameter> <!--CHANGE-->
- <parameter name="transport.vfs.ActionAfterProcess">MOVE</parameter>
- <parameter name="transport.vfs.ActionAfterFailure">MOVE</parameter>
-
- <target>
- <endpoint>
- <address format="soap12" uri="http://localhost:9000/services/SimpleStockQuoteService"/>
- </endpoint>
- <outSequence>
- <property name="transport.vfs.ReplyFileName"
- expression="fn:concat(fn:substring-after(get-property('MessageID'), 'urn:uuid:'), '.xml')" scope="transport"/>
- <property action="set" name="OUT_ONLY" value="true"/>
- <send>
- <endpoint>
- <address uri="vfs:file:///home/user/test/out"/> <!--CHANGE-->
- </endpoint>
- </send>
- </outSequence>
- </target>
- <publishWSDL uri="file:repository/conf/sample/resources/proxy/sample_proxy_1.wsdl"/>
- </proxy>
-</definitions>]]></pre>
+<pre xml:space="preserve"><definitions xmlns="http://ws.apache.org/ns/synapse">
+ <proxy name="StockQuoteProxy" transports="vfs">
+ <parameter name="transport.vfs.FileURI">file:///home/user/test/in</parameter> <!--CHANGE-->
+ <parameter name="transport.vfs.ContentType">text/xml</parameter>
+ <parameter name="transport.vfs.FileNamePattern">.*\.xml</parameter>
+ <parameter name="transport.PollInterval">15</parameter>
+ <parameter name="transport.vfs.MoveAfterProcess">file:///home/user/test/original</parameter> <!--CHANGE-->
+ <parameter name="transport.vfs.MoveAfterFailure">file:///home/user/test/original</parameter> <!--CHANGE-->
+ <parameter name="transport.vfs.ActionAfterProcess">MOVE</parameter>
+ <parameter name="transport.vfs.ActionAfterFailure">MOVE</parameter>
+
+ <target>
+ <endpoint>
+ <address format="soap12" uri="http://localhost:9000/services/SimpleStockQuoteService"/>
+ </endpoint>
+ <outSequence>
+ <property name="transport.vfs.ReplyFileName"
+ expression="fn:concat(fn:substring-after(get-property('MessageID'), 'urn:uuid:'), '.xml')" scope="transport"/>
+ <property action="set" name="OUT_ONLY" value="true"/>
+ <send>
+ <endpoint>
+ <address uri="vfs:file:///home/user/test/out"/> <!--CHANGE-->
+ </endpoint>
+ </send>
+ </outSequence>
+ </target>
+ <publishWSDL uri="file:repository/conf/sample/resources/proxy/sample_proxy_1.wsdl"/>
+ </proxy>
+</definitions></pre>
<p>
<strong>Objective: Using the file system as transport medium using VFS transport listener and sender</strong> </p>
<p>Start the Axis2 server and deploy the SimpleStockQuoteService if not already done </p>
@@ -2355,14 +2342,14 @@
<p>Copy SYNAPSE_HOME/repository/conf/sample/resources/vfs/test.xml to the directory given in transport.vfs.FileURI above. </p>
<p>test.xml file content is as follows </p>
<pre xml:space="preserve"><?xml version='1.0' encoding='UTF-8'?>
- <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:wsa="http://www.w3.org/2005/08/addressing">
- <soapenv:Body>
- <m0:getQuote xmlns:m0="http://services.samples/xsd">
- <m0:request>
- <m0:symbol>IBM</m0:symbol>
- </m0:request>
- </m0:getQuote>
- </soapenv:Body>
+ <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:wsa="http://www.w3.org/2005/08/addressing">
+ <soapenv:Body>
+ <m0:getQuote xmlns:m0="http://services.samples/xsd">
+ <m0:request>
+ <m0:symbol>IBM</m0:symbol>
+ </m0:request>
+ </m0:getQuote>
+ </soapenv:Body>
</soapenv:Envelope></pre>
<p>VFS transport listener will pick the file from
<em>in</em> directory and send it to the Axis2 service. The request XML file will be moved to
@@ -2371,30 +2358,30 @@
<h2>
<a name="Sample255" id="Sample255">Sample 255: Switching from ftp transport listener to mail transport sender</a></h2>
<pre xml:space="preserve"><definitions xmlns="http://ws.apache.org/ns/synapse">
- <proxy name="StockQuoteProxy" transports="vfs">
- <parameter name="transport.vfs.FileURI">vfs:ftp://guest:guest@localhost/test?vfs.passive=true</parameter> <!--CHANGE-->
- <parameter name="transport.vfs.ContentType">text/xml</parameter>
- <parameter name="transport.vfs.FileNamePattern">.*\.xml</parameter>
- <parameter name="transport.PollInterval">15</parameter>
-
- <target>
- <inSequence>
- <header name="Action" value="urn:getQuote"/>
- </inSequence>
- <endpoint>
- <address uri="http://localhost:9000/services/SimpleStockQuoteService"/>
- </endpoint>
- <outSequence>
- <property action="set" name="OUT_ONLY" value="true"/>
- <send>
- <endpoint>
- <address uri="mailto:user@host"/> <!--CHANGE-->
- </endpoint>
- </send>
- </outSequence>
- </target>
- <publishWSDL uri="file:repository/conf/sample/resources/proxy/sample_proxy_1.wsdl"/>
- </proxy>
+ <proxy name="StockQuoteProxy" transports="vfs">
+ <parameter name="transport.vfs.FileURI">vfs:ftp://guest:guest@localhost/test?vfs.passive=true</parameter> <!--CHANGE-->
+ <parameter name="transport.vfs.ContentType">text/xml</parameter>
+ <parameter name="transport.vfs.FileNamePattern">.*\.xml</parameter>
+ <parameter name="transport.PollInterval">15</parameter>
+
+ <target>
+ <inSequence>
+ <header name="Action" value="urn:getQuote"/>
+ </inSequence>
+ <endpoint>
+ <address uri="http://localhost:9000/services/SimpleStockQuoteService"/>
+ </endpoint>
+ <outSequence>
+ <property action="set" name="OUT_ONLY" value="true"/>
+ <send>
+ <endpoint>
+ <address uri="mailto:user@host"/> <!--CHANGE-->
+ </endpoint>
+ </send>
+ </outSequence>
+ </target>
+ <publishWSDL uri="file:repository/conf/sample/resources/proxy/sample_proxy_1.wsdl"/>
+ </proxy>
</definitions> </pre>
<p>
<strong>Objective: Switching from FTP transport listener to mail transport sender</strong> </p>
@@ -2410,46 +2397,46 @@
<p>VFS transport listener will pick the file from the directory in the FTP server and send it to the Axis2 service. The file in the FTP directory will be deleted. The response will be sent to the given email address. </p>
<h2>
<a name="Sample256" id="Sample256">Sample 256: Proxy services with the mail transport </a></h2>
-<pre xml:space="preserve"><![CDATA[<definitions xmlns="http://ws.apache.org/ns/synapse">
- <proxy name="StockQuoteProxy" transports="mailto">
+<pre xml:space="preserve"><definitions xmlns="http://ws.apache.org/ns/synapse">
+ <proxy name="StockQuoteProxy" transports="mailto">
+
+ <parameter name="transport.mail.Address">synapse.demo.1@gmail.com</parameter>
+ <parameter name="transport.mail.Protocol">pop3</parameter>
+ <parameter name="transport.PollInterval">5</parameter>
+ <parameter name="mail.pop3.host">pop.gmail.com</parameter>
+ <parameter name="mail.pop3.port">995</parameter>
+ <parameter name="mail.pop3.user">synapse.demo.1</parameter>
+ <parameter name="mail.pop3.password">mailpassword</parameter>
+ <parameter name="mail.pop3.socketFactory.class">javax.net.ssl.SSLSocketFactory</parameter>
+ <parameter name="mail.pop3.socketFactory.fallback">false</parameter>
+ <parameter name="mail.pop3.socketFactory.port">995</parameter>
+ <parameter name="transport.mail.ContentType">application/xml</parameter>
- <parameter name="transport.mail.Address">synapse.demo.1@gmail.com</parameter>
- <parameter name="transport.mail.Protocol">pop3</parameter>
- <parameter name="transport.PollInterval">5</parameter>
- <parameter name="mail.pop3.host">pop.gmail.com</parameter>
- <parameter name="mail.pop3.port">995</parameter>
- <parameter name="mail.pop3.user">synapse.demo.1</parameter>
- <parameter name="mail.pop3.password">mailpassword</parameter>
- <parameter name="mail.pop3.socketFactory.class">javax.net.ssl.SSLSocketFactory</parameter>
- <parameter name="mail.pop3.socketFactory.fallback">false</parameter>
- <parameter name="mail.pop3.socketFactory.port">995</parameter>
- <parameter name="transport.mail.ContentType">application/xml</parameter>
-
- <target>
- <inSequence>
- <property name="senderAddress" expression="get-property('transport', 'From')"/>
- <log level="full">
- <property name="Sender Address" expression="get-property('senderAddress')"/>
- </log>
- <send>
- <endpoint>
- <address uri="http://localhost:9000/services/SimpleStockQuoteService"/>
- </endpoint>
- </send>
- </inSequence>
- <outSequence>
- <property name="Subject" value="Custom Subject for Response" scope="transport"/>
- <header name="To" expression="fn:concat('mailto:', get-property('senderAddress'))"/>
- <log level="full">
- <property name="message" value="Response message"/>
- <property name="Sender Address" expression="get-property('senderAddress')"/>
- </log>
- <send/>
- </outSequence>
- </target>
- <publishWSDL uri="file:repository/conf/sample/resources/proxy/sample_proxy_1.wsdl"/>
- </proxy>
-</definitions>]]></pre>
+ <target>
+ <inSequence>
+ <property name="senderAddress" expression="get-property("transport", "From")"/>
+ <log level="full">
+ <property name="Sender Address" expression="get-property("senderAddress")"/>
+ </log>
+ <send>
+ <endpoint>
+ <address uri="http://localhost:9000/services/SimpleStockQuoteService"/>
+ </endpoint>
+ </send>
+ </inSequence>
+ <outSequence>
+ <property name="Subject" value="Custom Subject for Response" scope="transport"/>
+ <header name="To" expression="fn:concat("mailto:", get-property("senderAddress"))"/>
+ <log level="full">
+ <property name="message" value="Response message"/>
+ <property name="Sender Address" expression="get-property("senderAddress")"/>
+ </log>
+ <send/>
+ </outSequence>
+ </target>
+ <publishWSDL uri="file:repository/conf/sample/resources/proxy/sample_proxy_1.wsdl"/>
+ </proxy>
+</definitions></pre>
<p>
<strong>Objective: Using the mail transport with Proxy services</strong> </p>
<p>
@@ -2460,11 +2447,11 @@
<a href="Synapse_Samples_Setup.html#mailsender">Setting up mail transport sender</a> </p>
<p>Start the Synapse configuration numbered 256: i.e. synapse -sample 256 </p>
<p>Send an email with the following body and any custom Subject from your mail account. </p>
-<pre xml:space="preserve"><![CDATA[<getQuote xmlns="http://services.samples">
- <request xmlns="http://services.samples/xsd">
- <symbol>IBM</symbol>
- </request>
-</getQuote>]]></pre>
+<pre xml:space="preserve"><getQuote xmlns="http://services.samples">
+ <request xmlns="http://services.samples/xsd">
+ <symbol>IBM</symbol>
+ </request>
+</getQuote></pre>
<p>After a few seconds (e.g. 30s), you should receive a POX response in your email account with the stock quote reply. </p>
<p>Note that in this sample we used the <tt>transport.mail.ContentType</tt> property to make sure that the transport parses
the request message as POX. If you remove this property, you may still be able to send requests using a standard
@@ -2556,32 +2543,31 @@
<p>Synapse will forward the order request to the session with the Executor. The first response coming from the Executor will be sent back over HTTP. Executor generally sends two responses for each incoming order request. But since the response has to be forwarded over HTTP only one can be sent back to the client. </p>
<h2>
<a name="Sample259" id="Sample259">Sample 259: Switch from FIX to HTTP </a></h2>
-<pre xml:space="preserve"> <definitions xmlns="http://ws.apache.org/ns/synapse">
- <localEntry key="xslt-key-req"
- src="file:repository/conf/sample/resources/transform/transform_fix_to_http.xslt" />
- <proxy name="FIXProxy" transports="fix">
- <target>
- <endpoint>
- <address
- uri="http://localhost:9000/services/SimpleStockQuoteService" />
- </endpoint>
- <inSequence>
- <log level="full" />
- <xslt key="xslt-key-req" />
- <log level="full" />
- </inSequence>
- <outSequence>
- <log level="full" />
- </outSequence>
- </target>
- <parameter name="transport.fix.AcceptorConfigURL">
- file:repository/conf/sample/resources/fix/fix-synapse.cfg
- </parameter>
- <parameter name="transport.fix.AcceptorMessageStore">
- file
- </parameter>
- </proxy>
- </definitions>
+<pre xml:space="preserve"><definitions xmlns="http://ws.apache.org/ns/synapse">
+ <localEntry key="xslt-key-req" src="file:repository/conf/sample/resources/transform/transform_fix_to_http.xslt" />
+ <proxy name="FIXProxy" transports="fix">
+ <target>
+ <endpoint>
+ <address
+ uri="http://localhost:9000/services/SimpleStockQuoteService" />
+ </endpoint>
+ <inSequence>
+ <log level="full" />
+ <xslt key="xslt-key-req" />
+ <log level="full" />
+ </inSequence>
+ <outSequence>
+ <log level="full" />
+ </outSequence>
+ </target>
+ <parameter name="transport.fix.AcceptorConfigURL">
+ file:repository/conf/sample/resources/fix/fix-synapse.cfg
+ </parameter>
+ <parameter name="transport.fix.AcceptorMessageStore">
+ file
+ </parameter>
+ </proxy>
+</definitions>
</pre>
<p>
<strong>Objective: Demonstrate the capability of switching between FIX to HTTP</strong> </p>
@@ -2598,20 +2584,20 @@
<p>Open up the SYNAPSE_HOME/repository/conf/sample/synapse_sample_259.xml file and make sure that transport.fix.AcceptorConfigURL property points to the fix-synapse.cfg file you created. Once done you can start the Synapse configuration numbered 259: i.e. synapse -sample 259. Note that Synapse creates a new FIX session with Banzai at this point. </p>
<p>Send an order request from Banzai to Synapse. e.g. Buy DELL 1000 @ 100. User has to send a 'Limit' Order because price is a mandatory field for 'placeOrder' operation. </p>
<p>Synapse will forward the order request to one-way 'placeOrder' operation on the SimpleStockQuoteService. Synapse uses a simple XSLT mediator to transform the incoming FIX to a SOAP message. </p>
-<pre xml:space="preserve"> <xsl:stylesheet version="2.0"
- xmlns:xsl="http://www.w3.org/1999/XSL/Transform"
- xmlns:fn="http://www.w3.org/2005/02/xpath-functions">
- <xsl:output method="xml" omit-xml-declaration="yes" indent="yes" />
- <xsl:template match="/">
- <m0:placeOrder xmlns:m0="http://services.samples">
- <m0:order>
- <m0:price><xsl:value-of select="//message/body/field[@id='44']"/></m0:price>
- <m0:quantity><xsl:value-of select="//message/body/field[@id='38']"/></m0:quantity>
- <m0:symbol><xsl:value-of select="//message/body/field[@id='55']"/></m0:symbol>
- </m0:order>
- </m0:placeOrder>
- </xsl:template>
- </xsl:stylesheet>
+<pre xml:space="preserve"><xsl:stylesheet version="2.0"
+ xmlns:xsl="http://www.w3.org/1999/XSL/Transform"
+ xmlns:fn="http://www.w3.org/2005/02/xpath-functions">
+ <xsl:output method="xml" omit-xml-declaration="yes" indent="yes" />
+ <xsl:template match="/">
+ <m0:placeOrder xmlns:m0="http://services.samples">
+ <m0:order>
+ <m0:price><xsl:value-of select="//message/body/field[@id='44']"/></m0:price>
+ <m0:quantity><xsl:value-of select="//message/body/field[@id='38']"/></m0:quantity>
+ <m0:symbol><xsl:value-of select="//message/body/field[@id='55']"/></m0:symbol>
+ </m0:order>
+ </m0:placeOrder>
+ </xsl:template>
+</xsl:stylesheet>
</pre>
<p>To get an idea about the various transport parameters being used in this sample see
<a href="Synapse_Samples_Setup.html#fixparameters">FIX Transport Parameters </a>. </p>
@@ -2664,20 +2650,20 @@
<h2>
<a name="Sample261" id="Sample261">Sample 261: Switch between FIX versions </a></h2>
<pre xml:space="preserve"><definitions xmlns="http://ws.apache.org/ns/synapse">
- <proxy name="OrderProcesserProxy41" transports="fix">
- <target>
- <endpoint>
- <address uri="fix://localhost:19877?BeginString=FIX.4.1&amp;SenderCompID=SYNAPSE&amp;TargetCompID=EXEC"/>
- </endpoint>
- <inSequence><log level="full"/></inSequence>
- <outSequence><log level="full"/><send/></outSequence>
- </target>
- <parameter name="transport.fix.AcceptorConfigURL">file:repository/conf/sample/resources/fix/fix-synapse-m40.cfg</parameter>
- <parameter name="transport.fix.AcceptorMessageStore">file</parameter>
- <parameter name="transport.fix.InitiatorConfigURL">file:repository/conf/sample/resources/fix/synapse-sender-m.cfg</parameter>
- <parameter name="transport.fix.InitiatorMessageStore">file</parameter>
- </proxy>
- </definitions></pre>
+ <proxy name="OrderProcesserProxy41" transports="fix">
+ <target>
+ <endpoint>
+ <address uri="fix://localhost:19877?BeginString=FIX.4.1&amp;SenderCompID=SYNAPSE&amp;TargetCompID=EXEC"/>
+ </endpoint>
+ <inSequence><log level="full"/></inSequence>
+ <outSequence><log level="full"/><send/></outSequence>
+ </target>
+ <parameter name="transport.fix.AcceptorConfigURL">file:repository/conf/sample/resources/fix/fix-synapse-m40.cfg</parameter>
+ <parameter name="transport.fix.AcceptorMessageStore">file</parameter>
+ <parameter name="transport.fix.InitiatorConfigURL">file:repository/conf/sample/resources/fix/synapse-sender-m.cfg</parameter>
+ <parameter name="transport.fix.InitiatorMessageStore">file</parameter>
+ </proxy>
+</definitions></pre>
<p>
<strong>Objective: Demonstrate the capability of switching between FIX versions e.g. FIX4.0 to FIX4.1</strong> </p>
<p>
@@ -2688,9 +2674,9 @@
<pre xml:space="preserve">DataDictionary=~/etc/spec/FIX40-synapse.xml</pre>
<p>Note: FIX40-synapse.xml can be found at $SYNAPSE_HOME/repository/conf/samples/resources/fix. This is a custom FIX data dictionary file that has added tag 150,151 to the execution messages (35=8) of FIX4.0. Make sure the DataDictionary property of the banzai.cfg points to this data dictionary file. </p>
<p>Add the following lines to the Executor configuration file (executor.cfg). </p>
-<pre xml:space="preserve"> [session]
- BeginString=FIX.4.1
- SocketAcceptPort=19877</pre>
+<pre xml:space="preserve">[session]
+BeginString=FIX.4.1
+SocketAcceptPort=19877</pre>
<p>Start Banzai and Executor using the custom configuration files. </p>
<p>Enable FIX transport in the Synapse axis2.xml. See
<a href="Synapse_Samples_Setup.html#fixtransport">Setting up FIX transport </a> </p>
@@ -2703,48 +2689,48 @@
<h2>
<a name="Sample262" id="Sample262">Sample 262: CBR of FIX messages</a></h2>
<pre xml:space="preserve"><definitions xmlns="http://ws.apache.org/ns/synapse">
- <sequence name="CBR_SEQ">
- <in>
- <switch source="//message/body/field[@id='55']">
- <case regex="GOOG">
- <send>
- <endpoint>
- <address
- uri="fix://localhost:19876?BeginString=FIX.4.0&amp;SenderCompID=SYNAPSE&amp;TargetCompID=EXEC" />
- </endpoint>
- </send>
- </case>
- <case regex="MSFT">
- <send>
- <endpoint>
- <address
- uri="fix://localhost:19877?BeginString=FIX.4.1&amp;SenderCompID=SYNAPSE&amp;TargetCompID=EXEC" />
- </endpoint>
- </send>
- </case>
- <default></default>
- </switch>
- </in>
- <out>
- <send />
- </out>
- </sequence>
- <proxy name="FIXProxy" transports="fix">
- <target inSequence="CBR_SEQ" />
- <parameter name="transport.fix.AcceptorConfigURL">
- file:repository/conf/sample/resources/fix/fix-synapse.cfg
- </parameter>
- <parameter name="transport.fix.AcceptorMessageStore">
- file
- </parameter>
- <parameter name="transport.fix.InitiatorConfigURL">
- file:repository/conf/sample/resources/fix/synapse-sender.cfg
- </parameter>
- <parameter name="transport.fix.InitiatorMessageStore">
- file
- </parameter>
- </proxy>
- </definitions></pre>
+ <sequence name="CBR_SEQ">
+ <in>
+ <switch source="//message/body/field[@id='55']">
+ <case regex="GOOG">
+ <send>
+ <endpoint>
+ <address
+ uri="fix://localhost:19876?BeginString=FIX.4.0&amp;SenderCompID=SYNAPSE&amp;TargetCompID=EXEC" />
+ </endpoint>
+ </send>
+ </case>
+ <case regex="MSFT">
+ <send>
+ <endpoint>
+ <address
+ uri="fix://localhost:19877?BeginString=FIX.4.1&amp;SenderCompID=SYNAPSE&amp;TargetCompID=EXEC" />
+ </endpoint>
+ </send>
+ </case>
+ <default></default>
+ </switch>
+ </in>
+ <out>
+ <send />
+ </out>
+ </sequence>
+ <proxy name="FIXProxy" transports="fix">
+ <target inSequence="CBR_SEQ" />
+ <parameter name="transport.fix.AcceptorConfigURL">
+ file:repository/conf/sample/resources/fix/fix-synapse.cfg
+ </parameter>
+ <parameter name="transport.fix.AcceptorMessageStore">
+ file
+ </parameter>
+ <parameter name="transport.fix.InitiatorConfigURL">
+ file:repository/conf/sample/resources/fix/synapse-sender.cfg
+ </parameter>
+ <parameter name="transport.fix.InitiatorMessageStore">
+ file
+ </parameter>
+ </proxy>
+</definitions></pre>
<p>
<strong>Objective: Demonstrate the capability of CBR FIX messages</strong> </p>
<p>
@@ -2756,8 +2742,8 @@
<p>Note: FIX40-synapse.xml can be found at $SYNAPSE_HOME/repository/conf/samples/resources/fix. This is a custom FIX data dictionary file that has added tag 150,151 to the execution messages (35=8) of FIX4.0. Make sure the DataDictionary property of the banzai.cfg points to this data dictionary file. </p>
<p>Add the following lines to executor.cfg </p>
<pre xml:space="preserve">[session]
- BeginString=FIX.4.1
- SocketAcceptPort=19877</pre>
+BeginString=FIX.4.1
+SocketAcceptPort=19877</pre>
<p>Start Banzai and Executor using the custom config files. </p>
<p>Enable FIX transport in the Synapse axis2.xml. See
<a href="Synapse_Samples_Setup.html#fixtransport">Setting up FIX transport </a> </p>
@@ -2773,30 +2759,28 @@
<h2>
<a name="Sample263" id="Sample263">Sample 263: Transport switching - JMS to http/s using JBoss Messaging(JBM) </a></h2>
-<pre xml:space="preserve"><![CDATA[<definitions xmlns="http://ws.apache.org/ns/synapse">
-
- <proxy name="StockQuoteProxy" transports="jms">
- <target>
- <inSequence>
- <property action="set" name="OUT_ONLY" value="true"/>
- </inSequence>
- <endpoint>
- <address uri="http://localhost:9000/services/SimpleStockQuoteService"/>
- </endpoint>
- <outSequence>
- <send/>
- </outSequence>
- </target>
- <publishWSDL uri="file:repository/conf/sample/resources/proxy/sample_proxy_1.wsdl"/>
- <parameter name="transport.jms.ContentType">
- <rules>
- <jmsProperty>contentType</jmsProperty>
- <default>application/xml</default>
- </rules>
- </parameter>
- </proxy>
-
-</definitions>]]></pre>
+<pre xml:space="preserve"><definitions xmlns="http://ws.apache.org/ns/synapse">
+ <proxy name="StockQuoteProxy" transports="jms">
+ <target>
+ <inSequence>
+ <property action="set" name="OUT_ONLY" value="true"/>
+ </inSequence>
+ <endpoint>
+ <address uri="http://localhost:9000/services/SimpleStockQuoteService"/>
+ </endpoint>
+ <outSequence>
+ <send/>
+ </outSequence>
+ </target>
+ <publishWSDL uri="file:repository/conf/sample/resources/proxy/sample_proxy_1.wsdl"/>
+ <parameter name="transport.jms.ContentType">
+ <rules>
+ <jmsProperty>contentType</jmsProperty>
+ <default>application/xml</default>
+ </rules>
+ </parameter>
+ </proxy>
+</definitions></pre>
<p>
<strong>Objective: Introduction to switching transports with proxy services. The JMS provider will be <a href="http://jboss.org/jbossmessaging/">JBoss Messaging(JBM).</a></strong> </p>
<p>
@@ -2813,10 +2797,10 @@
</pre>
<p>Once you started the JBM server with the above changes you'll be able to see the following on STDOUT.</p>
<pre xml:space="preserve">10:18:02,673 INFO [org.jboss.messaging.core.server.impl.MessagingServerImpl] JBoss Messaging Server version 2.0.0.BETA3 (maggot, 104) started </pre>
-<p>You will now need to configure the Axis2 instance used by Synapse (not the sample Axis2 server) to enable JMS support using the above provider. Refer to the Axis2 documentation on setting up JMS for more details (http://ws.apache.org/axis2/1_1/jms-transport.html). You will also need to copy the jbm-core-client.jar, jbm-jms-client.jar, jnp-client.jar(these jars are inside client folder ) and
+<p>You will now need to configure the Axis2 instance used by Synapse (not the sample Axis2 server) to enable JMS support using the above provider. Refer Axis2 documentation on setting up JMS in detail (http://ws.apache.org/axis2/1_1/jms-transport.html). You will also need to copy the jbm-core-client.jar, jbm-jms-client.jar, jnp-client.jar(these jars are inside client folder ) and
jbm-transports.jar, netty.jar(these jars are from lib folder) jars from JBM into the lib directory to allow Synapse to connect to the JBM JMS provider. This was tested with JBM 2.0.0.BETA3 </p>
-<p>You need to add the following configuration for Axis2 transport listener in axis2.xml found at repository/conf/axis2.xml.</p>
+<p>You need to add the following configuration for Axis2 JMS transport listener in axis2.xml found at repository/conf/axis2.xml.</p>
<pre xml:space="preserve">
<transportReceiver name="jms" class="org.apache.axis2.transport.jms.JMSListener">
<parameter name="java.naming.factory.initial">org.jnp.interfaces.NamingContextFactory</parameter>
@@ -2825,8 +2809,8 @@
<parameter name="transport.jms.ConnectionFactoryJNDIName">ConnectionFactory</parameter>
</transportReceiver>
</pre>
-<p>And also uncomment the section for JMS transport sender.</p>
-<p>Once you start the Synapse configuration and request for the WSDL of the proxy service (http://localhost:8280/services/StockQuoteProxy?wsdl) you will notice that its exposed only on the JMS transport. This is because the configuration specified this requirement in the proxy service definition. </p>
+<p>And also uncomment the section for JMS transport sender in the same file.</p>
+<p>Once you start the Synapse configuration 250 and request for the WSDL of the proxy service (http://localhost:8280/services/StockQuoteProxy?wsdl) you will notice that its exposed only on the JMS transport. This is because the configuration specified this requirement in the proxy service definition. </p>
<p>Now lets send a stock quote request on JMS, using the dumb stock quote client as follows: </p>
<pre xml:space="preserve">ant jmsclient -Djms_type=pox -Djms_dest=StockQuoteProxy -Djms_payload=MSFT -Djava.naming.provider.url=jnp://localhost:1099 -Djava.naming.factory.initial=org.jnp.interfaces.NamingContextFactory -D=java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces</pre>
<p>On the Synapse debug log you will notice that the JMS listener received the request message as: </p>