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 2010/09/26 07:09:54 UTC
svn commit: r1001358 - in /synapse/trunk/java: repository/conf/sample/
repository/conf/sample/resources/fix/ repository/conf/sample/resources/vfs/
src/site/xdoc/
Author: hiranya
Date: Sun Sep 26 05:09:54 2010
New Revision: 1001358
URL: http://svn.apache.org/viewvc?rev=1001358&view=rev
Log:
Fixing some samples
Modified:
synapse/trunk/java/repository/conf/sample/resources/fix/synapse-sender-m.cfg
synapse/trunk/java/repository/conf/sample/resources/vfs/test.xml
synapse/trunk/java/repository/conf/sample/synapse_sample_258.xml
synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml
synapse/trunk/java/src/site/xdoc/Synapse_Samples_Setup.xml
Modified: synapse/trunk/java/repository/conf/sample/resources/fix/synapse-sender-m.cfg
URL: http://svn.apache.org/viewvc/synapse/trunk/java/repository/conf/sample/resources/fix/synapse-sender-m.cfg?rev=1001358&r1=1001357&r2=1001358&view=diff
==============================================================================
--- synapse/trunk/java/repository/conf/sample/resources/fix/synapse-sender-m.cfg (original)
+++ synapse/trunk/java/repository/conf/sample/resources/fix/synapse-sender-m.cfg Sun Sep 26 05:09:54 2010
@@ -13,8 +13,9 @@ ConnectionType=initiator
[session]
BeginString=FIX.4.0
SocketConnectPort=19876
+
[session]
-BeginString=FIX.4.2
+BeginString=FIX.4.1
SocketConnectPort=19877
Modified: synapse/trunk/java/repository/conf/sample/resources/vfs/test.xml
URL: http://svn.apache.org/viewvc/synapse/trunk/java/repository/conf/sample/resources/vfs/test.xml?rev=1001358&r1=1001357&r2=1001358&view=diff
==============================================================================
--- synapse/trunk/java/repository/conf/sample/resources/vfs/test.xml (original)
+++ synapse/trunk/java/repository/conf/sample/resources/vfs/test.xml Sun Sep 26 05:09:54 2010
@@ -2,7 +2,7 @@
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:wsa="http://www.w3.org/2005/08/addressing">
<soapenv:Body>
<getQuote xmlns="http://services.samples">
- <request xmlns="http://services.samples/xsd">
+ <request>
<symbol>IBM</symbol>
</request>
</getQuote>
Modified: synapse/trunk/java/repository/conf/sample/synapse_sample_258.xml
URL: http://svn.apache.org/viewvc/synapse/trunk/java/repository/conf/sample/synapse_sample_258.xml?rev=1001358&r1=1001357&r2=1001358&view=diff
==============================================================================
--- synapse/trunk/java/repository/conf/sample/synapse_sample_258.xml (original)
+++ synapse/trunk/java/repository/conf/sample/synapse_sample_258.xml Sun Sep 26 05:09:54 2010
@@ -21,7 +21,7 @@
<!-- HTTP to FIX Proxy Service -->
<definitions xmlns="http://synapse.apache.org/ns/2010/04/configuration">
- <proxy name="FIXProxy">
+ <proxy name="FIXProxy" transports="http">
<target>
<endpoint>
<address
@@ -40,7 +40,7 @@
</target>
<parameter name="transport.fix.InitiatorConfigURL">
- file:/home/hiranya/Desktop/fix-config/synapse-sender.cfg
+ file:repository/conf/sample/resources/fix/synapse-sender.cfg
</parameter>
<parameter name="transport.fix.InitiatorMessageStore">file</parameter>
<parameter name="transport.fix.SendAllToInSequence">false</parameter>
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=1001358&r1=1001357&r2=1001358&view=diff
==============================================================================
--- synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml (original)
+++ synapse/trunk/java/src/site/xdoc/Synapse_Samples.xml Sun Sep 26 05:09:54 2010
@@ -2095,15 +2095,27 @@ Connection: Keep-Alive
<strong>Objective: Introduction to switching transports with proxy services</strong> </p>
<p>
<strong>Prerequisites:</strong>
-<br/> Start the Axis2 server and deploy the SimpleStockQuoteService (Refer steps above)
+<br/> Start the Axis2 server with the SimpleStockQuoteService deployed
<br/> Download, install and start a JMS server, and configure Synapse to listen on JMS (refer notes below)
-<br/> Start the Synapse configuration numbered 250: i.e. synapse -sample 250
-<br/> For this example we would use ActiveMQ as the JMS provider. Once ActiveMQ is installed and started you should get a message as follows: </p>
-<pre xml:space="preserve">INFO BrokerService - ActiveMQ JMS Message Broker (localhost) 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 ActiveMQ client jar files activeio-core-3.0-beta1.jar, activemq-core-4.0-RC2.jar and geronimo-j2ee-management_1.0_spec-1.0.jar into the lib directory to allow Synapse to connect to the JMS provider. </p>
-<p>For a default ActiveMQ v4.0 installation, you may uncomment the Axis2 transport listener configuration found at repository/conf/axis2.xml as </p>
+<br/> Start the Synapse configuration numbered 250: i.e. synapse -sample 250</p>
+
+<p> For this example we will use <a href="http://activemq.apache.org">Apache ActiveMQ</a> as the JMS provider.
+Simply download the binary distribution, extract it and launch the startup script to start the JMS broker.</p>
+<p>Now you have to enable the JMS transport receiver of Synapse. Start by deploying the ActiveMQ client
+libraries into the Synapse runtime. Simply copy the following jars from the ActiveMQ distribution into
+SYNAPSE_HOME/lib directory:</p>
+<ul>
+ <li>activemq-core.jar</li>
+ <li>geronimo-j2ee_management.jar</li>
+ <li>geronimo-jms.jar</li>
+</ul>
+<p>Now you need to add some entries into the axis2.xml file. For a default ActiveMQ v5.x installation, you may
+uncomment the Axis2 transport listener configuration found at repository/conf/axis2.xml as </p>
<pre xml:space="preserve"><transportReceiver name="jms" class="org.apache.axis2.transport.jms.JMSListener"> ...</pre>
-<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>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>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=dynamicQueues/StockQuoteProxy -Djms_payload=MSFT</pre>
<p>On the Synapse debug log you will notice that the JMS listener received the request message as: </p>
@@ -2143,11 +2155,12 @@ it will first try to read the content ty
<strong>Objective: Demonstrate switching from HTTP to JMS</strong> </p>
<p>
<strong>Prerequisites:</strong>
-<br/> Download, install and start a JMS server </p>
-<p>Configure sample Axis2 server for JMS (refer notes above)
+<br/> Download, install and start a JMS server
+<br/> Configure sample Axis2 server for JMS (refer notes below)
<br/> Start the Axis2 server and deploy the SimpleStockQuoteService (see below)
<br/> Configure the Synase JMS transport (refer notes above - sample 250)
<br/> Start the Synapse configuration numbered 251: i.e. synapse -sample 251 </p>
+
<p>To switch from HTTP to JMS, edit the samples/axis2Server/repository/conf/axis2.xml for the sample Axis2 server and enable JMS (refer notes above), and restart the server. Now you can see that the simple stock quote service is available in both JMS and HTTP in the sample Axis2 server. To see this, point your browser to the WSDL of the service at http://localhost:9000/services/SimpleStockQuoteService?wsdl. JMS URL for the service is mentioned as below: </p>
<pre xml:space="preserve">jms:/SimpleStockQuoteService?transport.jms.ConnectionFactoryJNDIName=
QueueConnectionFactory&java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory&
@@ -2383,16 +2396,20 @@ Transfer-Encoding: chunked
</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>
-<p>Create three new directories in a test directory. e.g. in, out, original in /home/user/test. Open SYNAPSE_HOME/repository/conf/sample/synapse_sample_254.xml and edit the following values. Change transport.vfs.FileURI, transport.vfs.MoveAfterProcess, transport.vfs.MoveAfterFailure parameter values to the above in, original, original directories respectively. Change outSequence endpoint address uri to out directory with the prefix
-<em>vfs:</em>. Values you have to change are marked with <!--CHANGE-->. </p>
-<p>Start the Synapse configuration numbered 254: i.e. synapse -sample 254 </p>
+
+<p>
+<strong>Prerequisites:</strong>
+<br/>Start the Axis2 server and deploy the SimpleStockQuoteService if not already done
+<br/>Create three new directories in a test directory. e.g. in, out, original in /home/user/test. Open SYNAPSE_HOME/repository/conf/sample/synapse_sample_254.xml and edit the following values. Change transport.vfs.FileURI, transport.vfs.MoveAfterProcess, transport.vfs.MoveAfterFailure parameter values to the above in, original, original directories respectively. Change outSequence endpoint address uri to out directory with the prefix
+<em>vfs:</em>. Values you have to change are marked with <!--CHANGE-->
+<br/>Start the Synapse configuration numbered 254: i.e. synapse -sample 254 </p>
+
<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:getQuote xmlns:m0="http://services.samples">
<m0:request>
<m0:symbol>IBM</m0:symbol>
</m0:request>
@@ -2538,13 +2555,13 @@ mail clients don't allow the user to exp
<p>
<strong>Prerequisites:</strong>
<br/> You will need the two sample FIX applications that come with Quickfix/J (Banzai and Executor). Configure the two applications to establish sessions with Synapse. See
-<a href="Synapse_Samples_Setup.html#fixsamplesconfig">Configuring Sample FIX Applications</a> </p>
-<p>Start Banzai and Executor </p>
-<p>Enable FIX transport in the Synapse axis2.xml. See
-<a href="Synapse_Samples_Setup.html#fixtransport">Setting up FIX transport </a> </p>
-<p>Configure Synapse for FIX samples. See
-<a href="Synapse_Samples_Setup.html#fixsamples">Configuring Synapse for FIX Samples</a> </p>
-<p>Open up the SYNAPSE_HOME/repository/conf/sample/synapse_sample_257.xml file and make sure that transport.fix.AcceptorConfigURL property points to the fix-synapse.cfg file you created. Also make sure that transport.fix. InitiatorConfigURL property points to the synapse-sender.cfg file you created. Once done you can start the Synapse configuration numbered 257: i.e. synapse -sample 257. Note that Synapse creates new FIX sessions with Banzai and Executor at this point. </p>
+<a href="Synapse_Samples_Setup.html#fixsamplesconfig">Configuring Sample FIX Applications</a>
+<br/>Start Banzai and Executor
+<br/>Enable FIX transport in the Synapse axis2.xml. See
+<a href="Synapse_Samples_Setup.html#fixtransport">Setting up FIX transport </a>
+<br/>Configure Synapse for FIX samples. See
+<a href="Synapse_Samples_Setup.html#fixsamples">Configuring Synapse for FIX Samples</a>
+<br/>Open up the SYNAPSE_HOME/repository/conf/sample/synapse_sample_257.xml file and make sure that transport.fix.AcceptorConfigURL property points to the fix-synapse.cfg file you created. Also make sure that transport.fix. InitiatorConfigURL property points to the synapse-sender.cfg file you created. Once done you can start the Synapse configuration numbered 257: i.e. synapse -sample 257. Note that Synapse creates new FIX sessions with Banzai and Executor at this point. </p>
<p>Send an order request from Banzai to Synapse. </p>
<p>Synapse will forward the order request to the session with the Executor. The responses coming from the Executor will be sent back to Banzai. </p>
<p>To get an idea about the various transport parameters being used in this sample see
@@ -2552,7 +2569,7 @@ mail clients don't allow the user to exp
<h2>
<a name="Sample258" id="Sample258">Sample 258: Switching from HTTP to FIX </a></h2>
<pre xml:space="preserve"><definitions xmlns="http://synapse.apache.org/ns/2010/04/configuraiton">
- <proxy name="FIXProxy">
+ <proxy name="FIXProxy" transport"http">
<parameter name="transport.fix.InitiatorConfigURL">file:/home/synapse_user/fix-config/synapse-sender.cfg</parameter>
<parameter name="transport.fix.InitiatorMessageStore">file</parameter>
@@ -2579,13 +2596,14 @@ mail clients don't allow the user to exp
<p>
<strong>Prerequisites:</strong>
<br/> You will need the Executor sample application that comes with Quickfix/J. Configure Executor to establish a session with Synapse. See
-<a href="Synapse_Samples_Setup.html#fixsamplesconfig">Configuring Sample FIX Applications</a> </p>
-<p>Start Executor. </p>
-<p>Enable FIX transport sender in the Synapse axis2.xml. See
-<a href="Synapse_Samples_Setup.html#fixtransport">Setting up FIX transport </a> </p>
-<p>Configure Synapse for FIX samples. See
-<a href="Synapse_Samples_Setup.html#fixsamples">Configuring Synapse for FIX Samples</a>. There is no need to create the fix-synapse.cfg file for this sample. Having only the synapse-sender.cfg file is sufficient. </p>
-<p>Go to the SYNAPSE_HOME/repository/conf/sample/synapse_sample_258.xml file and make sure that transport.fix.InitiatorConfigURL property points to the synapse-sender.cfg file you created. Once done you can start the Synapse configuration numbered 258: i.e. synapse -sample 258 </p>
+<a href="Synapse_Samples_Setup.html#fixsamplesconfig">Configuring Sample FIX Applications</a>
+<br/>Start Executor
+<br/>Enable FIX transport sender in the Synapse axis2.xml. See
+<a href="Synapse_Samples_Setup.html#fixtransport">Setting up FIX transport </a>
+<br/>Configure Synapse for FIX samples. See
+<a href="Synapse_Samples_Setup.html#fixsamples">Configuring Synapse for FIX Samples</a>. There is no need to create the fix-synapse.cfg file for this sample. Having only the synapse-sender.cfg file is sufficient.
+<br/>Go to the SYNAPSE_HOME/repository/conf/sample/synapse_sample_258.xml file and make sure that transport.fix.InitiatorConfigURL property points to the synapse-sender.cfg file you created. Once done you can start the Synapse configuration numbered 258: i.e. synapse -sample 258 </p>
+
<p>Invoke the FIX Client as follows. This command sends a FIX message embedded in a SOAP message over HTTP.
<pre>ant fixclient -Dsymbol=IBM -Dqty=5 -Dmode=buy -Daddurl=http://localhost:8280/services/FIXProxy</pre> </p>
<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>
@@ -2622,14 +2640,15 @@ mail clients don't allow the user to exp
<p>
<strong>Prerequisites:</strong>
<br/> You will need the sample FIX blotter that come with Quickfix/J (Banzai). Configure the blotter to establish sessions with Synapse. See
-<a href="Synapse_Samples_Setup.html#fixsamplesconfig">Configuring Sample FIX Applications</a> </p>
-<p>Start the Axis2 server and deploy the SimpleStockQuoteService if not already deployed </p>
-<p>Start Banzai </p>
-<p>Enable FIX transport in the Synapse axis2.xml. See
-<a href="Synapse_Samples_Setup.html#fixtransport">Setting up FIX transport </a> </p>
-<p>Configure Synapse for FIX samples. See
-<a href="Synapse_Samples_Setup.html#fixsamples">Configuring Synapse for FIX Samples</a> </p>
-<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>
+<a href="Synapse_Samples_Setup.html#fixsamplesconfig">Configuring Sample FIX Applications</a>
+<br/>Start the Axis2 server and deploy the SimpleStockQuoteService if not already deployed
+<br/>Start Banzai
+<br/>Enable FIX transport in the Synapse axis2.xml. See
+<a href="Synapse_Samples_Setup.html#fixtransport">Setting up FIX transport </a>
+<br/>Configure Synapse for FIX samples. See
+<a href="Synapse_Samples_Setup.html#fixsamples">Configuring Synapse for FIX Samples</a>
+<br/>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"
Modified: synapse/trunk/java/src/site/xdoc/Synapse_Samples_Setup.xml
URL: http://svn.apache.org/viewvc/synapse/trunk/java/src/site/xdoc/Synapse_Samples_Setup.xml?rev=1001358&r1=1001357&r2=1001358&view=diff
==============================================================================
--- synapse/trunk/java/src/site/xdoc/Synapse_Samples_Setup.xml (original)
+++ synapse/trunk/java/src/site/xdoc/Synapse_Samples_Setup.xml Sun Sep 26 05:09:54 2010
@@ -604,42 +604,38 @@ synapse.sh -sample <n></pre>
<p>
Put the following entries in a file called fix-synapse.cfg
- <pre>
- [default]
- FileStorePath=examples/target/data/synapse-acceptor
- ConnectionType=acceptor
- StartTime=00:00:00
- EndTime=00:00:00
- HeartBtInt=30
- ValidOrderTypes=1,2,F
- SenderCompID=SYNAPSE
- TargetCompID=BANZAI
- UseDataDictionary=Y
- DefaultMarketPrice=12.30
-
- [session]
- BeginString=FIX.4.0
- SocketAcceptPort=9876
- </pre>
+ <pre>[default]
+FileStorePath=examples/target/data/synapse-acceptor
+ConnectionType=acceptor
+StartTime=00:00:00
+EndTime=00:00:00
+HeartBtInt=30
+ValidOrderTypes=1,2,F
+SenderCompID=SYNAPSE
+TargetCompID=BANZAI
+UseDataDictionary=Y
+DefaultMarketPrice=12.30
+
+[session]
+BeginString=FIX.4.0
+SocketAcceptPort=9876</pre>
</p>
<p>
Put the following entries in a file called synapse-sender.cfg
- <pre>
- [default]
- FileStorePath=examples/target/data/synapse-initiator
- SocketConnectHost=localhost
- StartTime=00:00:00
- EndTime=00:00:00
- HeartBtInt=30
- ReconnectInterval=5
- SenderCompID=SYNAPSE
- TargetCompID=EXEC
- ConnectionType=initiator
-
- [session]
- BeginString=FIX.4.0
- SocketConnectPort=19876
- </pre>
+ <pre>[default]
+FileStorePath=examples/target/data/synapse-initiator
+SocketConnectHost=localhost
+StartTime=00:00:00
+EndTime=00:00:00
+HeartBtInt=30
+ReconnectInterval=5
+SenderCompID=SYNAPSE
+TargetCompID=EXEC
+ConnectionType=initiator
+
+[session]
+BeginString=FIX.4.0
+SocketConnectPort=19876</pre>
</p>
<h3 id="fixsamplesconfig">
@@ -648,44 +644,40 @@ synapse.sh -sample <n></pre>
<p>
Locate and edit the FIX configuration file of Executor to be as follows.
This file is usually named executor.cfg
- <pre>
- [default]
- FileStorePath=examples/target/data/executor
- ConnectionType=acceptor
- StartTime=00:00:00
- EndTime=00:00:00
- HeartBtInt=30
- ValidOrderTypes=1,2,F
- SenderCompID=EXEC
- TargetCompID=SYNAPSE
- UseDataDictionary=Y
- DefaultMarketPrice=12.30
-
- [session]
- BeginString=FIX.4.0
- SocketAcceptPort=19876
- </pre>
+ <pre>[default]
+FileStorePath=examples/target/data/executor
+ConnectionType=acceptor
+StartTime=00:00:00
+EndTime=00:00:00
+HeartBtInt=30
+ValidOrderTypes=1,2,F
+SenderCompID=EXEC
+TargetCompID=SYNAPSE
+UseDataDictionary=Y
+DefaultMarketPrice=12.30
+
+[session]
+BeginString=FIX.4.0
+SocketAcceptPort=19876</pre>
</p>
<p>
Locate and edit the FIX configuration file of Banzai to be as follows.
This file is usually named banzai.cfg
- <pre>
- [default]
- FileStorePath=examples/target/data/banzai
- ConnectionType=initiator
- SenderCompID=BANZAI
- TargetCompID=SYNAPSE
- SocketConnectHost=localhost
- StartTime=00:00:00
- EndTime=00:00:00
- HeartBtInt=30
- ReconnectInterval=5
-
- [session]
- BeginString=FIX.4.0
- SocketConnectPort=9876
- </pre>
- </p>
+ <pre>[default]
+FileStorePath=examples/target/data/banzai
+ConnectionType=initiator
+SenderCompID=BANZAI
+TargetCompID=SYNAPSE
+SocketConnectHost=localhost
+StartTime=00:00:00
+EndTime=00:00:00
+HeartBtInt=30
+ReconnectInterval=5
+
+[session]
+BeginString=FIX.4.0
+SocketConnectPort=9876</pre>
+ </p>
<p>
The FileStorePath property in the above two files should point
to two directories in your local file system.