How to create Java Mapping in SAP PI / PO

Hi Manoj,

You can use below code to test locally in the eclipse.In eclipse the main method will be called but in PI main method will not be called so same code you can use it in PI and locally in eclipse.

package za.co.pnp.sap.pi.mapping.pmt.statement;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.FileOutputStream;

import java.io.InputStream;

import java.io.OutputStream;

import com.sap.aii.mapping.api.AbstractTransformation;

import com.sap.aii.mapping.api.StreamTransformationException;

import com.sap.aii.mapping.api.TransformationInput;

import com.sap.aii.mapping.api.TransformationOutput;

public class Test_JavaMapping extends AbstractTransformation {

    public static void main(String[] args) throws StreamTransformationException {

        FileInputStream fin = null;

        FileOutputStream fout = null;

        try {

            fin = new FileInputStream("source.txt");

            fout = new FileOutputStream("target.txt");

        } catch (FileNotFoundException e) {

            e.printStackTrace();

        }

        Test_JavaMapping javaMap = new Test_JavaMapping();

        javaMap.execute(fin, fout);

    }

    @Override

    public void transform(TransformationInput transformationIn, TransformationOutput transformationOut)

            throws StreamTransformationException {

        execute(transformationIn.getInputPayload().getInputStream(), transformationOut.getOutputPayload()

                .getOutputStream());

    }

    public void execute(InputStream inputStream, OutputStream outputStream) throws StreamTransformationException {

        try {

            // Copy Input content to Output content

            byte[] b = new byte[inputStream.available()];

            inputStream.read(b);

            outputStream.write("Prefixing this line to input. Test_JavaMapping. \r\n".getBytes());

            outputStream.write(b);

        } catch (Exception exception) {

            getTrace().addDebugMessage(exception.getMessage());

            throw new StreamTransformationException(exception.toString());

        }

    }

}

Regards,

Praveen.