Objective: Using the file
Table of Contents |
---|
Introduction
This sample demonstrates how to use the file system as an input medium using via the inbound file listener.
Prerequisites
- Start the Axis2 server and deploy the
SimpleStockQuoteService
if not already done - Create three Create 3 new directories named in, out and original in a test directory , for example, in, out, original in (e.g., /home/user/test. Open ESB_HOME) in the local file system. Then, open the
<ESB_HOME>/repository/samples/synapse_sample_900.
xml and edit the following values. Changexml
file in a text editor and change thetransport.vfs.FileURI
,transport.vfs.MoveAfterProcess
,transport.vfs.MoveAfterFailure
parameter parameter values to the above the in, original, and original directories directory locations respectively. - Start the Synapse configuration numbered 900:
wso2esb-samples.sh -sn 900
- Copy
ESB_HOME/repository/samples/resources/vfs/test.xml
to the directory given intransport.vfs.FileURI
above.
Building the sample
The XML configuration for this sample is as follows:
Code Block | ||||
---|---|---|---|---|
| ||||
<definitions xmlns="http://ws.apache.org/ns/synapse"> <registry provider="org.wso2.carbon.mediation.registry.WSO2Registry"> <parameter name="cachableDuration">15000</parameter> </registry> <taskManager provider="org.wso2.carbon.mediation.ntask.NTaskTaskManager"> <parameter name="cachableDuration">15000</parameter> </taskManager> <inboundEndpoint xmlns="http://ws.apache.org/ns/synapse" name="file_inbound" sequence="request" onError="fault" protocol="file" suspend="false"> <parameters> <parameter name="interval">1000</parameter> <parameter name="sequential">true</parameter> <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.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> </parameters> </inboundEndpoint> <sequence name="request" onError="fault"> <call> <endpoint> <address format="soap12" uri="http://localhost:9000/services/SimpleStockQuoteService"/> </endpoint> </call> <drop/> </sequence> </definitions> |
...
This configuration file synapse_sample_900.xml
is available in the <ESB_HOME>/repository/samples
directory.
To build the sample
Start the ESB with the sample 900 configuration. For instructions on starting a sample ESB configuration, see Starting the ESB with a sample configuration.
The operation log keeps running until the server starts, which usually takes several seconds. Wait until the server has fully booted up and displays a message similar to "WSO2 Carbon started in n seconds."Start the Axis2 server. For instructions on starting the Axis2 server, see Starting the Axis2 server.
Deploy the back-end service SimpleStockQuoteService. For instructions on deploying sample back-end services, see Deploying sample back-end services.
Executing the sample
To execute the sample client
Copy the
ESB_HOME/repository/samples/resources/vfs/test.xml
file to the location specified intransport.vfs.FileURI
in the configuration (i.e., the in directory).
Thetest.xml
file contains a simple stock quote request and is as follows:Code Block language html/xml <?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"> <m0:request> <m0:symbol>IBM</m0:symbol> </m0:request> </m0:getQuote> </soapenv:Body> </soapenv:Envelope>
...
Analyzing the output
You will see that the inbound polling file listener picks the file from in directory and send sends it to the Axis2 service. The , and that the request XML file will be is moved to the process directory.
Excerpt | ||
---|---|---|
| ||
Example of using the file system as input medium in WSO2 ESB. |