Page Comparison

Objective: Demonstrate the smooks mediator EDI message processing.

Introduction

This sample demonstrates how the Smooks mediator in WSO2 ESB is used to process an EDI message before sending it to the back-end service. In this demonstration, you will deploy a sample back-end service in WSO2 ESB, and then provide an EDI message as the input. The Smooks mediator configuration will then translate the EDI message to XML. The ESB sequence will further process the XML message, and the Iterate mediator will send the message to the back-end service.

Prerequisites

For a list of prerequisites, see Prerequisites to Start Samples.

Building the sample

Here is the sample with smooks Smooks mediator.

<definitions xmlns="http://ws.apache.org/ns/synapse">
    <localEntry key="transform-xslt-key"
                src="file:repositorysamples/samplesservice-bus/resources/smooks/transform.xslt"/>
    <localEntry key="smooks-key" src="file:repositorysamples/samplesservice-bus/resources/smooks/smooks-config.xml"/>
    <proxy name="StockQuoteProxy" transports="vfs">
        <parameter name="transport.vfs.ContentType">text/plain</parameter>
        <!--CHANGE-->
        <parameter name="transport.vfs.ContentType">text/plain</parameter>
       <parameter name="transport.vfs.FileURI">file:///home/user/dev/test/smooks/in</parameter>
       <parameter name="transport.vfs.FileNamePattern">.*\.txt</parameter>
        <parameter name="transport.PollInterval">5</parameter>
        <!--CHANGE-->
        <parameter name="transport.vfs.MoveAfterProcess">file:///home/user/dev/test/smooks/original</parameter>
        <!--CHANGE-->
        <parameter name="transport.vfs.MoveAfterFailure">file:///home/user/dev/test/smooks/original</parameter>
        <parameter name="transport.vfs.ActionAfterProcess">MOVE</parameter>
        <parameter name="transport.vfs.ActionAfterFailure">MOVE</parameter>
        <parameter name="Operation">urn:placeOrder</parameter>
        <target>
            <inSequence>
                <smooks config-key="smooks-key"/>
                <xslt key="transform-xslt-key"/>
                <iterate expression="//m0:placeOrder/m0:order" preservePayload="true"
                         attachPath="//m0:placeOrder" xmlns:m0="http://services.samples">
                    <target>
                        <sequence>
                            <header name="Action" value="urn:placeOrder"/>
                            <property action="set" name="OUT_ONLY" value="true"/>
                            <send>
                                <endpoint>
                                    <address format="soap11"
                                            uri="http://localhost:9000/services/SimpleStockQuoteService"/>
                                </endpoint>
                            </send>
                        </sequence>
                    </target>
                </iterate>
            </inSequence>
            <outSequence/>
        </target>
        <publishWSDL uri="file:repositorysamples/samplesservice-bus/resources/smooks/PlaceStockOrder.wsdl"/>
    </proxy>
</definitions>

...

To build the sample:

1. Deploy the back-end service (SimpleStockQuoteService) in the Axis2 server. For instructions on deploying sample

...

1. back-end services, see Deploying sample back-end services.

2. Start the Axis2 server. For instructions on starting the Axis2 server, see Starting the Axis2 server.

3. Enable the plain text message builder in the axis2.xml file (found in the <ESB_HOME>/repository/conf directory) as shown below.

   Code Block
   language html/xml
   <messageBuilder contentType="text/plain" class="org.apache.axis2.format.PlainTextBuilder"/>

...

1. Enable

...

1. the vfs transport in the axis2.

...

1. xml file by

...

1. uncommenting the vfs transport sender and receiver configurations

...

1. as shown below.

   Code Block
   <transportReceiver name="vfs" class="org.apache.synapse.transport.vfs.VFSTransportListener"/> <transportSender name="vfs" class="org.apache.synapse.transport.vfs.VFSTransportSender"/>

2. Create three folders on your computer for the following purposes:

   • To store the original text file with the EDI message.

   • To store the text file with the EDI message after the file has been successfully processed by the Smooks mediator.
   • To store the text file with the EDI message if the file processing fails.

3. Update the sample configuration file (which is the synapse_sample_654.xml

...

1.  file found in the <ESB_HOME>/repository/samples

...

1. / directory) with the paths to the folders created in the previous step. Listed below are the

...

• transport.vfs.FileURI
• transport.vfs.MoveAfterProcess
• transport.vfs.ActionAfterFailure

4. Start ESB with the sample configuration 654 (i.e. wso2esb-samples.sh -sn 654).

...

1. parameters you need to update:

   • transport.vfs.FileURI: This parameter specifies the path to the folder that stores the text file with the EDI message.
   • transport.vfs.MoveAfterProcess: This specifies the path to the folder that stores the same text file after it is successfully converted by the Smooks mediator.
   • transport.vfs.ActionAfterFailure: This specifies the path to the folder that stores the same text file if an error occurs during the processing.

   See the following example of the sample configuration:

   Code Block
   <parameter name="transport.vfs.FileURI">file:///home/user/test/in</parameter> <parameter name="transport.vfs.MoveAfterProcess">file:///home/user/test/original</parameter> <parameter name="transport.vfs.MoveAfterFailure">file:///home/user/test/original</parameter>

Executing the sample

Now you need to add a text file with an EDI message to the folder you specified for the transport.vfs.FileURI parameter in the sample configuration and run the sample. WSO2 ESB is shipped with a sample text file with an EDI message: This is the edi.txt file stored in the <ESB_HOME>/repository/samples/resources/smooks directory. 

1. Copy the edi.txt file to the folder you specified for the transport.vfs.FileURI parameter in the sample configuration.
2. Start WSO2 ESB with the sample 654 configuration. For instructions on starting a sample configuration, see Starting 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."

Analyzing the output

The Smooks mediator will first translate the EDI message into XML as shown below.

HDR*1200*2008-01-01
ORD*50.00*500*IBM*REF 10053
ORD*170.00*100*MSFT*--
ORD*85.00*200*SUN*A1249
ORD*138.00*100*IBM*--
ORD*18.00*500*MSFT*ref 20088398289

<?xml version='1.0' encoding='utf-8'?><soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"><soapenv:Body><orders>
	<header>
		<batch-id>1200</batch-id>
		<date>2008-01-01</date>
	</header>
	<order>
		<price>50.00</price>
		<quantity>500</quantity>
		<symbol>IBM</symbol>
		<comment>REF 10053</comment>
	</order>
	<order>
		<price>170.00</price>
		<quantity>100</quantity>
		<symbol>MSFT</symbol>
		<comment>--</comment>
	</order>
	<order>
		<price>85.00</price>
		<quantity>200</quantity>
		<symbol>SUN</symbol>
		<comment>A1249</comment>
	</order>
	<order>
		<price>138.00</price>
		<quantity>100</quantity>
		<symbol>IBM</symbol>
		<comment>--</comment>
	</order>
	<order>
		<price>18.00</price>
		<quantity>500</quantity>
		<symbol>MSFT</symbol>
		<comment>ref 20088398289</comment>
	</order>
</orders>
</soapenv:Body></soapenv:Envelope>

The XML shown above will then be transformed into the following format after XSLT translation:

<?xml version='1.0' encoding='utf-8'?><soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"><soapenv:Body><m0:placeOrder xmlns:m0="http://services.samples">
   <m0:order>
      <m0:price>50.00</m0:price>
      <m0:quantity>500</m0:quantity>
      <m0:symbol>IBM</m0:symbol>
   </m0:order>
   <m0:order>
      <m0:price>170.00</m0:price>
      <m0:quantity>100</m0:quantity>
      <m0:symbol>MSFT</m0:symbol>
   </m0:order>
   <m0:order>
      <m0:price>85.00</m0:price>
      <m0:quantity>200</m0:quantity>
      <m0:symbol>SUN</m0:symbol>
   </m0:order>
   <m0:order>
      <m0:price>138.00</m0:price>
      <m0:quantity>100</m0:quantity>
      <m0:symbol>IBM</m0:symbol>
   </m0:order>
   <m0:order>
      <m0:price>18.00</m0:price>
      <m0:quantity>500</m0:quantity>
      <m0:symbol>MSFT</m0:symbol>
   </m0:order>
</m0:placeOrder>
</soapenv:Body></soapenv:Envelope>

The XML message (after XSLT translation) is then sent to the back-end service (SimpleStockQuoteService) by the Iterate mediator. You can see how the contents of the above message (orders) are received by the SimpleStockQuoteService, by checking the logs in the Axis2 server's terminal:

Accepted order #12 for : 200 stocks of SUN at $ 85.0
Accepted order #13 for : 500 stocks of IBM at $ 50.0
Accepted order #11 for : 100 stocks of MSFT at $ 170.0
Accepted order #14 for : 100 stocks of IBM at $ 138.0
Accepted order #15 for : 500 stocks of MSFT at $ 18.0