FTP

1. Select the Remote Transfer checkbox
2. Select SFTP from drop down in the transfer protocol property

• Enter the FTP server address and the port number, for example 9.20.192.15:21

mqsisetdbparms -w workDir -n ftp::secId -u <userName> -p <password>

mqsisetdbparms -w C:\ACE12NODEWS\TEST_SERVER -n ftp::DUMMYFTP -u builduser-p builduser

Here DUMMYFTP is the Server identity given in IBM App Connect Enterprise Console to run:

Server Directory: specify the directory on the FTP server where the files are located (for File input node) or the directory where the files should be uploaded (for File Output node). For example: /incoming/ for reading files or /outgoing/ for writing files.

FTP endpoint details screen:

The file will be automatically deleted from the server after it is read successfully.

If you are still facing issues with FTPClient in your Java Compute Node code, then add that jar in project build path.

package com.ibm.acp.ace.ftp.example;

import com.ibm.broker.javacompute.MbJavaComputeNode;

import com.ibm.broker.plugin.MbElement;

import com.ibm.broker.plugin.MbException;

import com.ibm.broker.plugin.MbMessage;

import com.ibm.broker.plugin.MbMessageAssembly;

import com.ibm.broker.plugin.MbOutputTerminal;

import com.ibm.broker.plugin.MbUserException;

import org.apache.commons.net.ftp.FTPClient;

import java.io.IOException;

public class AcpToAceFileName extends MbJavaComputeNode {

    @Override

    public void evaluate(MbMessageAssembly inAssembly) throws MbException {

        MbOutputTerminal out = getOutputTerminal("out");

        MbMessage inMessage = inAssembly.getMessage();

        MbMessage outMessage = new MbMessage(inMessage);

        MbMessageAssembly outAssembly = new MbMessageAssembly(inAssembly, outMessage);

        FTPClient ftpClient = new FTPClient();

        try {

            // Step 1: Get file information from LocalEnvironment

            MbElement localEnv = inAssembly.getLocalEnvironment().getRootElement();

            String localDirectory = null;

            String localFileName = null;

            if (localEnv.getFirstElementByPath("$LocalEnvironment/Destination/File/Directory") != null) {

                localDirectory = localEnv.getFirstElementByPath("$LocalEnvironment/Destination/File/Directory").getValueAsString();

            }

            if (localEnv.getFirstElementByPath("$LocalEnvironment/File/Name") != null) {

                localFileName = localEnv.getFirstElementByPath("$LocalEnvironment/File/Name").getValueAsString();

            }

            // Log the local directory and file name

            System.out.println("Local Directory: " + localDirectory);

            System.out.println("Local File Name: " + localFileName);

            // Step 2: Connect to the FTP server

            String ftpHost = "9.20.192.15"; 

            int ftpPort = 21;              

            String ftpUser = "builduser";  

            String ftpPassword = "builduser"; 

            String remoteDirectory = "/MyTest/VendorImport/Dummy/POLLTO"; 

            ftpClient.connect(ftpHost, ftpPort);

            ftpClient.login(ftpUser, ftpPassword);

            // Step 3: List files in the remote FTP directory

            String[] ftpFileList = ftpClient.listNames(remoteDirectory);

            // Log the list of files retrieved from the FTP server

            if (ftpFileList != null) {

                System.out.println("Files in FTP directory:");

                for (String fileName : ftpFileList) {

                    System.out.println(fileName);

                }

            } else {

                System.out.println("No files found in the FTP directory.");

            }

            // Step 4: Build output message

            MbElement outRoot = outMessage.getRootElement();

            MbElement outBody = outRoot.createElementAsLastChild(MbElement.TYPE_NAME, "XMLNSC", null);

            MbElement fileListElement = outBody.createElementAsLastChild(MbElement.TYPE_NAME, "FileDetails", null);

            // Add local file details from FileOutput Node

            if (localDirectory != null) {

                fileListElement.createElementAsLastChild(MbElement.TYPE_NAME_VALUE, "LocalDirectory", localDirectory);

            }

            if (localFileName != null) {

                fileListElement.createElementAsLastChild(MbElement.TYPE_NAME_VALUE, "LocalFileName", localFileName);

            }

            // Add file names from FTP server

            if (ftpFileList != null) {

                MbElement ftpFilesElement = fileListElement.createElementAsLastChild(MbElement.TYPE_NAME, "FTPFiles", null);

                for (String fileName : ftpFileList) {

                    ftpFilesElement.createElementAsLastChild(MbElement.TYPE_NAME_VALUE, "File", fileName);

                }

            }

            // Step 5: Disconnect from FTP server

            ftpClient.logout();

            ftpClient.disconnect();

        } catch (IOException e) {

            throw new MbUserException(this, "evaluate", "", "", e.toString(), null);

        }

        // Propagate the message to the next node

        out.propagate(outAssembly);

    }

}

mqsisetdbparms -w workDir -n sftp::myidentity -u <myuserid> -p <mypassword>

mqsisetdbparms -w C:\ACE12NODEWS\TEST_SERVER -n sftp::SFTPSERIDENTITY -u user1 -p Access2sftpuser

workDir with the working directory of your integration server

myidentity with a name for the security identity

userName with the SFTP server username

password with the SFTP server password

Specify the directory on the SFTP server where the files are located (for FileInput node) or the directory where the files should be uploaded (for FileOutput node). For example: /incoming/ for reading files or /outgoing/ for writing files.

SFTP endpoint details screen:

keystoreType: 'JKS'

keystoreFile: C:/Users/Administrator/keystore.jks

keystorePass: <password> (Replace <password> with the actual keystore password)

truststoreType: 'JKS'

truststoreFile: C:/Users/Administrator/truststore.jks

truststorePass: <password> (Replace <password> with the actual truststore password)