Skip to content

ISO8583 Inbound Endpoint Example

In the real world, financial scenarios are happening among thousands of banking systems and networks. In this situation, one system needs to act as a message publisher, and another system needs to be capable of receiving messages. Once the message is received, further processing actions are performed based on the logic that is implemented in the internal system.

The ISO8583 inbound endpoint of WSO2 acts as a message consumer. The ISO8583 inbound endpoint is a listening inbound endpoint that can consume ISO8583 standard messages. It then converts the messages to XML format and injects messages to a sequence in the integration runtime.

What you'll build

This scenario demonstrates how the ISO8583 inbound endpoint works as an ISO8583 message consumer. In this scenario, to generate ISO8583 messages we use a sample Java client program.

The ISO8583 inbound endpoint listens on port 5000 and acts as a ISO8583 standard message consumer. When a sample Java client connects on port 5000, the ISO8583 inbound endpoint consumes ISO8583 standard messages, converts the messages to XML format, and then injects messages to a sequence in the integration runtime.

See ISO8583 connector configuration for more information. However, for simplicity of this example, we will just log the message. You can extend the sample as required using WSO2 mediators.

The following diagram illustrates all the required functionality of the ISO8583 inbound operations that you are going to build.

For example, while transferring bank and financial sector information using the ISO85883 message format among the banking networks, the message receiving can be done by using inbound endpoints. The ISO8583 inbound endpoint of WSO2 acts as an ISO8583 message receiver. You can inject that message into the mediation flow for getting the required output.

ISO8583 inbound operations

Set up the integration project

  1. Add a new custom inbound endpoint by clicking + icon in the Inbound Endpoints.
    Creating inbound endpoint

  2. Under the Basic section set the Class field to org.wso2.carbon.inbound.iso8583.listening.ISO8583MessageConsumer.

  3. Navigate to the source view and update it with the following configuration as required. 

<?xml version="1.0" encoding="UTF-8"?><inboundEndpoint xmlns="http://ws.apache.org/ns/synapse" name="custom_listener" sequence="requestISO" onError="fault" class="org.wso2.carbon.inbound.iso8583.listening.ISO8583MessageConsumer" suspend="false">
    <parameters>
        <parameter name="inbound.behavior">listening</parameter>
        <parameter name="sequential">true</parameter>
        <parameter name="coordination">true</parameter>
        <parameter name="port">5000</parameter>
        <parameter name="isProxy">false</parameter>
    </parameters>
</inboundEndpoint>
Sequence to process the message.

In this example for simplicity we will just log the message, but in a real world use case, this can be any type of message mediation.

<?xml version="1.0" encoding="UTF-8"?><sequence xmlns="http://ws.apache.org/ns/synapse" name="requestISO" onError="fault">
    <log level="full">
        <property name="Log_Message for ISO8583 Inbound Endpoint" value="Message received from sample1-source"/>
    </log>
</sequence>

Export integration logic as a CApp

In order to export the project, refer to the build and export the carbon application guide.

Deployment

  1. Navigate to the connector store and search for ISO8583. Click on ISO8583 Inbound Endpoint and download the .jar file by clicking on Download Inbound Endpoint. Copy this .jar file into /deployment/libs folder.

  2. Download jpos-1.9.4.jar, jdom-1.1.3.jar, and commons-cli-1.3.1.jar and add it to /deployment/libs folder.

In order to deploy and run the project, refer the build and run guide.

Test

  1. Run Test Client program. Use a ISO8583 standard message as input;
0200B220000100100000000000000002000020134500000050000001115221801234890610000914XYRTUI5269TYUI021ABCDEFGHIJ 1234567890

Expected response

[2020-03-26 15:47:26,003]  INFO {org.apache.synapse.mediators.builtin.LogMediator} - To: , MessageID: urn:uuid:FB34DB1FB26FB57D561585217845823, Direction: request, Log_Message for ISO8583 Inbound Endpoint = Message received from sample1-source, Envelope: 
<?xml version="1.0" encoding="UTF-8"?>
<soapenv:Envelope xmlns:soapenv="http://www.w3.org/2003/05/soap-envelope">
   <soapenv:Body>
      <ISOMessage>
         <header>AHc=</header>
         <data>
            <field id="0">0200</field>
            <field id="3">201345</field>
            <field id="4">000000500000</field>
            <field id="7">0111522180</field>
            <field id="11">123489</field>
            <field id="32">100009</field>
            <field id="44">XYRTUI5269TYUI</field>
            <field id="111">ABCDEFGHIJ 1234567890</field>
         </data>
      </ISOMessage>
   </soapenv:Body>
</soapenv:Envelope>