Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • You will need the sample FIX blotter that comes with Quickfix/J (Banzai). Configure the blotter to establish sessions with Synapse.
  • Configure the AMQP transport for WSO2 ESB.
  • Start the AMQP consumer, by switching to samples/axis2Client directory and running the consumer using the following command. Consumer will listen to the queue QpidStockQuoteService, accept the orders and reply to the queue replyQueue.

    Code Block
    ant amqpconsumer \-Dpropfile=$ESB_HOME/repository/samples/resources/fix/direct.properties
    
  • Start Banzai.
  • Enable FIX transport in the Synapse axis2.xml.
  • Configure Synapse for FIX samples.
  • Open up the ESB_HOME/repository/samples/synapse_sample_260.xml file and make sure that the transport.fix.AcceptorConfigURL property points to the fix-synapse.cfg file you created. Once done, you can start the Synapse configuration numbered 260: wso2esb-samples.sh -sn 260.

    Info
    titleNote

    Synapse creates a new FIX session with Banzai at this point.

  • Send an order request from Banzai to Synapse. For example, Buy DELL 1000 @ MKT.
Code Block
linenumberstrue
<definitions xmlns="http://ws.apache.org/ns/synapse">
    <proxy name="FIXProxy" transports="fix">
        <target>
            <endpoint>
                <address uri="jms:/QpidStockQuoteService?transport.jms.ConnectionFactoryJNDIName=qpidConnectionfactory&amp;java.naming.factory.initial=org.apache.qpid.jndi.PropertiesFileInitialContextFactory&amp;java.naming.provider.url=repository/conf/sample/resources/fix/con.properties&amp;transport.jms.ReplyDestination=replyQueue"/>
            </endpoint>
            <inSequence>
                <log level="full" />
            </inSequence>
            <outSequence>
                <property name="transport.fix.ServiceName"
                    value="FIXProxy" scope="axis2-client" />
                <log level="full" />
                        <send />
            </outSequence>
        </target>
        <parameter name="transport.fix.AcceptorConfigURL">
            file:repository/conf/sample/resources/fix/fix-synapse.cfg
        </parameter>
        <parameter name="transport.fix.AcceptorMessageStore">
            file
        <>file</parameter>
    </proxy>
</definitions>

...