int sshPort = Integer.parseInt(sshPortStr);

            JSch jsch = new JSch();

            Session session = jsch.getSession(user, host, sshPort);

            java.util.Properties config = new java.util.Properties();

            config.put(STRICTHOSTKEYCHECKING, strictHostKeyChecking);

            session.setConfig(config);

            session.setPassword(password);

            session.connect();

            // Remember that this is just for testing and we need a quick

            // access, you can add an identity and known_hosts file to prevent

            // Man In the Middle attacks

            Channel channel = session.openChannel("sftp");

            channel.connect();

            ChannelSftp sftp = (ChannelSftp) channel;

/*
 *
 * IBM and Sterling Commerce Confidential 
 *
 * OCO Source Materials 
 *
 * IBM B2B Sterling Integrator 
 *
 * (c) Copyright Sterling Commerce, an IBM Company 2001, 2011
 *
 * The source code for this program is not published or otherwise
 * divested of its trade secrets, irrespective of what has been
 * deposited with the U.S. Copyright Office. 
 *
 */
package com.sterlingcommerce.woodstock.services.integration.IBMGPFSClientService;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InterruptedIOException;
import java.io.OutputStream;
import java.rmi.RemoteException;

import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelExec;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.JSchException;
import com.jcraft.jsch.Session;
import com.jcraft.jsch.SftpException;
import com.sterlingcommerce.woodstock.services.IService;
import com.sterlingcommerce.woodstock.services.ServiceStoppedException;
import com.sterlingcommerce.woodstock.util.frame.log.LogService;
import com.sterlingcommerce.woodstock.util.frame.log.Logger;
import com.sterlingcommerce.woodstock.workflow.WorkFlowContext;
import com.sterlingcommerce.woodstock.workflow.WorkFlowException;

/**
 * 
 * @author Bipin Chandra
 */
public class IBMGPFSClientService implements IService {
    protected static Logger log;
    static {
        log = (Logger) LogService.getLogger("integrationservices");
    }
    private static boolean isOK = true;
    private static final String STRICTHOSTKEYCHECKING = "StrictHostKeyChecking";

    @Override
    public WorkFlowContext processData(WorkFlowContext wfc)
            throws RemoteException, WorkFlowException, ServiceStoppedException,
            InterruptedIOException {
        isOK = true;
        try {
            wfc.harnessRegister();
            String action = wfc.getParm("operation");// PUT,  DELETE
            String user = wfc.getParm("username");
            String host = wfc.getParm("gpfs_system_ip_address");// GPFS system ip
            String password = wfc.getParm("password");
            String local_path = wfc.getParm("local_path");// Path to read file from for uploading
            // String localFile = "C:\\localfile.txt";
            String remote_path = wfc.getParm("remote_path");
            // String remoteFile = "/root/localfile.txt";
            String sshPortStr = wfc.getParm("ssh_port");
            String strictHostKeyChecking = wfc.getParm("StrictHostKeyChecking");
            String messageId = wfc.getParm("messageId");// Message ID for mailbox

            log.log("IBMGPFSClientService.processData(): action:" + action);
            log.log("IBMGPFSClientService.processData(): user:" + user);
            log.log("IBMGPFSClientService.processData(): host:" + host);
            log.log("IBMGPFSClientService.processData(): password:" + password);
            log.log("IBMGPFSClientService.processData(): local_path:" + local_path);
            log.log("IBMGPFSClientService.processData(): remote_path:" + remote_path);
            log.log("IBMGPFSClientService.processData(): sshPort:" + sshPortStr);
            log.log("IBMGPFSClientService.processData(): strictHostKeyChecking:" + strictHostKeyChecking);
            log.log("IBMGPFSClientService.processData(): messageId:" + messageId);

            int sshPort = Integer.parseInt(sshPortStr);
            JSch jsch = new JSch();
            Session session = jsch.getSession(user, host, sshPort);
            java.util.Properties config = new java.util.Properties();
            config.put(STRICTHOSTKEYCHECKING, strictHostKeyChecking);
            session.setConfig(config);
            session.setPassword(password);
            session.connect();

            if ("put".equalsIgnoreCase(action)) {
                putFileToGPFS(session, remote_path, local_path);
            } else if ("delete".equalsIgnoreCase(action)) {
                log.log("Usage: IBMGPFSclient delete <s3_key>");
                delete(session, remote_path);
            } else {
                log.log("Usage: Incorrect Operation - It should be put/delete");
            }
            log.log("Done!");
        } catch (Exception e) {
            isOK = false;
            log.log(e.getMessage());
            log.logException(e);
            wfc.setBasicStatus(1);
            throw new WorkFlowException(e.toString());
        } finally {
            wfc.unregisterThread();
            if (isOK) {
                wfc.setBasicStatusSuccess();
            } else {
                wfc.setBasicStatusError();
            }
        }
        return wfc;
    }

    private void putFileToGPFS(Session session, String remote_path,
            String local_path) throws IOException {
        FileInputStream fis = null;
        boolean ptimestamp = true;
        try {
            // exec 'scp -t rfile' remotely
            String command = "scp " + (ptimestamp ? "-p" : "") + " -t " + remote_path;
            Channel channel = session.openChannel("exec");
            ((ChannelExec) channel).setCommand(command);

            // get I/O streams for remote scp
            OutputStream out = channel.getOutputStream();
            InputStream in = channel.getInputStream();

            channel.connect();

            if (checkAck(in) != 0) {
                return;
            }

            File _lfile = new File(local_path);

            if (ptimestamp) {
                command = "T " + (_lfile.lastModified() / 1000) + " 0";
                // The access time should be sent here,
                // but it is not accessible with JavaAPI ;-<
                command += (" " + (_lfile.lastModified() / 1000) + " 0\n");
                out.write(command.getBytes());
                out.flush();
                if (checkAck(in) != 0) {
                    return;
                }
            }

            // send "C0644 filesize filename", where filename should not include
            // '/'
            long filesize = _lfile.length();
            command = "C0644 " + filesize + " ";
            if (local_path.lastIndexOf('/') > 0) {
                command += local_path
                        .substring(local_path.lastIndexOf('/') + 1);
            } else {
                command += local_path;
            }
            command += "\n";
            out.write(command.getBytes());
            out.flush();
            if (checkAck(in) != 0) {
                return;
            }

            // send a content of lfile
            fis = new FileInputStream(local_path);
            byte[] buf = new byte[1024];
            while (true) {
                int len = fis.read(buf, 0, buf.length);
                if (len <= 0)
                    break;
                out.write(buf, 0, len); // out.flush();
            }
            fis.close();
            fis = null;
            // send '\0'
            buf[0] = 0;
            out.write(buf, 0, 1);
            out.flush();
            if (checkAck(in) != 0) {
                return;
            }
            out.close();

            channel.disconnect();
            session.disconnect();
            return;
        } catch (Exception e) {
            System.out.println(e);
            try {
                if (fis != null)
                    fis.close();
            } catch (Exception ee) {
            }
        }
    }

    private int checkAck(InputStream in) throws IOException {
        int b = in.read();
        // b may be 0 for success,
        // 1 for error,
        // 2 for fatal error,
        // -1
        if (b == 0)
            return b;
        if (b == -1)
            return b;

        if (b == 1 || b == 2) {
            StringBuffer sb = new StringBuffer();
            int c;
            do {
                c = in.read();
                sb.append((char) c);
            } while (c != '\n');
            if (b == 1) { // error
                System.out.print(sb.toString());
            }
            if (b == 2) { // fatal error
                System.out.print(sb.toString());
            }
        }
        return b;
    }

    private void delete(Session session, String remotePath) {
        try {
            // Remember that this is just for testing and we need a quick
            // access, you can add an identity and known_hosts file to prevent
            // Man In the Middle attacks
            Channel channel = session.openChannel("sftp");
            channel.connect();
            ChannelSftp sftp = (ChannelSftp) channel;
            // use the get method , if you are using android remember to remove
            // "file://" and use only the relative path
            sftp.rm(remotePath);
            Boolean success = true;
            if (success) {
                // The file has been DELETED succesfully
                System.out.println("ScpTo.remove(): SUCCESS");
            }
            channel.disconnect();
            session.disconnect();
        } catch (JSchException e) {
            System.out.println(e.getMessage().toString());
            e.printStackTrace();
        } catch (SftpException e) {
            System.out.println(e.getMessage().toString());
            e.printStackTrace();
        }
    }
}

-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

<process name="IBMGPFSClientProcess">
  <sequence>
        <operation name="Extract File">
          <participant name='TestGPFSClientForB2Bi'/>
          <output message='xout'>
            <assign to='.' from='PrimaryDocument' />
          </output>
         <input message="xin">
           <assign to="." from="*"/>
         </input>
        </operation>
  </sequence>
</process>

<?xml version="1.0" encoding="UTF-8"?>
<services>
 <service parentdefname="IBMGPFSClientForB2Bi" name="TestGPFSClientForB2Bi"
         displayname="TestGPFSClientForB2Bi" description="IBM GPFS Service for Sterling B2B Integrator"
         targetenv="all" activestatus="1" systemservice="0" parentdefid="-1"/>
</services>