Switching from HTTP to FIX

This example demonstrates how ESB Micro Integrator receives messages in HTTP and forwards them through FIX.

Synapse will create a session with the Executor and forward the order request. The first response coming from the Executor will be sent back over HTTP. The 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.

Synapse configuration

Following are the integration artifacts (proxy service) that we can used to implement this scenario. See the instructions on how to build and run this example.

<?xml version="1.0" encoding="UTF-8"?>
<proxy xmlns="http://ws.apache.org/ns/synapse" name="HTTPToFIXProxy" startOnLoad="true">
    <description />
    <target>
        <inSequence>
            <log level="full"></log>
            <property name="transport.fix.ServiceName" value="HTTPToFIXProxy" scope="axis2-client" />
            <send>
                <endpoint>
                    <address uri="fix://localhost:19876?BeginString=FIX.4.0&amp;SenderCompID=SYNAPSE&amp;TargetCompID=EXEC" />
                </endpoint>
            </send>
        </inSequence>
        <outSequence>
            <log level="full"></log>
            <send />
        </outSequence>
    </target>
    <parameter name="transport.fix.InitiatorConfigURL">file:/{file_path}/synapse-sender.cfg</parameter>
    <parameter name="transport.fix.InitiatorMessageStore">file</parameter>
    <parameter name="transport.fix.SendAllToInSequence">false</parameter>
    <parameter name="transport.fix.DropExtraResponses">true</parameter>
</proxy>

Build and Run

Create the artifacts:

  1. Set up ESB Integration Studio.
  2. Create an integration project with an ESB Configs module and an Composite Exporter.
  3. Create the proxy service with the configurations given above.
  4. Download the FIX transport resources from here and change the {file_path} of the proxy with the downloaded location.
  5. Deploy the artifacts in your Micro Integrator.

Enable the FIX transport and start the Micro-Integrator.

Run the quickfixj Executor sample application.

java -jar quickfixj-examples-executor-2.1.1.jar

Send the following request to the Micro Integrator and we will receive the response from the executor application.

curl -X POST \
  http://localhost:8290/services/HTTPToFIXProxy \
  -H 'cache-control: no-cache' \
  -H 'content-type: text/xml' \
  -H 'soapaction: \"urn:mediate\"' \
  -d '<?xml version="1.0" encoding="UTF-8"?>
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
   <soapenv:Header />
   <soapenv:Body>
      <message>
         <header>
            <field id="35">D</field>
            <field id="52">Fri Nov 08 11:04:31 IST 2019</field>
         </header>
         <body>
            <field id="11">122333</field>
            <field id="21">1</field>
            <field id="38">5</field>
            <field id="40">1</field>
            <field id="54">1</field>
            <field id="55">IBM</field>
            <field id="59">0</field>
         </body>
         <trailer />
      </message>
   </soapenv:Body>
</soapenv:Envelope>'
Top